天天看点

关于ActiveMQ 消息接收和转发

关于ActiveMQ的东西如果不是这次出差,我还真没怎么用过,以前只是用过openJMS。这次用ActiveMQ 主要是用来解决一个问题:linux C++写的消息客户端向 window 2003Server Java服务器端发送消息。而服务器端要求所有其他客户端服务器以ISO8859-1的编码格式发送,由于消息中涉及到中文,而由C++写的消息客户端发送的内容,服务器一直接收的是乱码(这个问题知道怎么回事的给我留个言,3Q)。然后没办法,公司要求我在现场自己用java 写的转发的程序,主要功能就是接收C++客户端以UTF-8的编码方式发送过来的消息,然后再用JAVA转码成ISO8859-1的方式发送给第三方消息服务器。

要实现的功能很简单,消息客户端是Linux 系统用C++实现的ActiveMQ Client,转发服务器是Linux系统用JAVA实现消息的接收并将消息转码后发送,消息服务器是Windows 2003 Server用JAVA实现ActiveMQ Server.转发代码如下:

中间涉及到从properties 文件中读取的参数是Topic名称和Broker

-----自己学习,仅作记录-----

继续阅读