如何用Apache Camel实现从ActiveMQ到Netty服务端Socket的数据接收

核心问题分析 #

你的代码中，从ActiveMQ转发消息到Netty服务端的逻辑存在几个潜在问题：

1. 消息格式不匹配：你设置了textline=true，意味着Netty端点会按**文本行（带换行符）**格式发送消息，但如果ActiveMQ中的消息没有换行符，Netty服务端会一直等待完整的行数据，导致无法接收。
2. 连接状态验证缺失：未明确配置连接超时，且未确认Netty服务端是否正常监听6666端口、是否能处理对应格式的消息。

修正方案 #

1. 适配文本行格式要求 #

如果Netty服务端确实按文本行处理消息，需要在转发时给消息添加换行符，确保Netty服务端能识别完整消息：

from("activemq:Test?exchangePattern=InOnly")
    .log("log:Sending message from -->${body}")
    // 给消息末尾添加换行符，适配textline=true的格式要求
    .setBody(simple("${body}\n"))
    .to("netty:tcp://localhost:6666?textline=true&sync=false&clientMode=true&connectTimeout=5000");

2. 非文本行场景的配置调整 #

如果Netty服务端不是按文本行处理消息，直接移除textline=true，改用默认的字节流传输：

from("activemq:Test?exchangePattern=InOnly")
    .log("log:Sending message from -->${body}")
    .to("netty:tcp://localhost:6666?sync=false&clientMode=true&connectTimeout=5000");

关键排查步骤 #

• 确认Netty服务端已启动并正常监听6666端口，可通过telnet localhost 6666或端口检测工具验证。
• 查看Camel日志，检查是否有连接Netty服务端的异常日志，或消息发送成功的记录。
• 在Netty服务端添加调试日志，确认是否接收到连接请求或消息数据。
• 检查ActiveMQ的Test队列，确认消息已被Camel路由消费（队列消息数减少）。

内容的提问来源于stack exchange，提问作者Om Prakash