解决ActiveMQ中,Java与C++交互中文乱码问题

摘要

最近在尝试使用ActiveMQ做系统间的继承,当然少不了Java和C++客户端的交互问题。由于Java与C++在字符串上采用了不同方式的编码(Java-Unicode, C++ – ascii)造成了

环境:

C++ 端:

操作系统:         Win7

JMS客户端:     CMS 3.1.2 (新版本的CMS需要VS2008编译)

开发环境:         VS2005

Java端:

操作系统:          WinXp

JMS客户端:       ActiveMQ5.4.1-Core

开发环境:           JDK1.6.22

ActiveMQ:

ActiveMQ 5.4.1

解决方法:

根据JMS API对Message类别的定义,最适合多语言见交互的Message类型应该是BytesMessage和TextMessage。由于BytesMessage的readUTF方法在CMS3.1.2中,接收Java端发出的UTF字符时会抛出异常,导致BytesMessage不好使用;

TextMessage中,无论C++端以哪种格式的数据setText() , Java端接收到的数据都是以ISO-8859-1格式编码的字符。所以统一在发送和接收时都采用 ISO-8859-1 的方式进行数据传输

发送时的代码:

private void writeTextMessage(String txt) {  
    try {  
        String msg = txt;         

        String iso = new String(txt.getBytes("GBK"), "ISO-8859-1");  

        TextMessage message = pubSession.createTextMessage();  
        message.setStringProperty("language", "java");  
        message.setText(iso);  

        pub.publish(message);  

    } catch (JMSException e) {  
        e.printStackTrace();  
    } catch (UnsupportedEncodingException e) {  
        e.printStackTrace();  
    }   
}

接收时的代码:

private void onTextMessage(TextMessage message) throws JMSException {  
    String txt = message.getText();  

    try {  
        String gbk = new String(txt.getBytes("ISO-8859-1"), "GBK");  
        System.out.println(gbk);  
    } catch (UnsupportedEncodingException e) {  
        e.printStackTrace();  
    }  
}

Update1: 2011-07-26 10:00

CMS版本不是1.0版,应该是3.1.2

IT家园
IT家园

网友最新评论 (0)