Java连接MQ，发送和读取

import java.io.IOException;   
import com.ibm.mq.MQC;   
import com.ibm.mq.MQEnvironment;   
import com.ibm.mq.MQException;   
import com.ibm.mq.MQMessage;   
import com.ibm.mq.MQPutMessageOptions;   
import com.ibm.mq.MQQueue;   
import com.ibm.mq.MQQueueManager;   
  
public class MQSender implements Runnable {   
    private static final String MQ_MANAGER = "QM2";   
    private static final String MQ_HOST_NAME = "10.0.16.15";   
    private static final String MQ_CHANNEL = "service2";   // "SYSTEM.DEF.SVRCONN";//
    private static final String MQ_QUEUE_NAME = "LQ1";   
    private static final int MQ_PROT = 1434;   
    private static final int MQ_CCSID = 1208;
  
    public void run() {   
        MQQueueManager mqQueueManager = null;   
        MQQueue mqQueue = null;
        try {   
            MQEnvironment.addConnectionPoolToken();   
            MQEnvironment.hostname = MQ_HOST_NAME;   
            MQEnvironment.channel = MQ_CHANNEL ;  
            MQEnvironment.port = MQ_PROT;   
            MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);   
            MQEnvironment.CCSID = MQ_CCSID;   
            int sendOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;   
            mqQueueManager = new MQQueueManager(MQ_MANAGER);   
            mqQueue = mqQueueManager.accessQueue(MQ_QUEUE_NAME, sendOptions, null, null, null);   
            MQPutMessageOptions mqPutMessageOptions = new MQPutMessageOptions();   
            MQMessage mqMessage = null;   
            String putMessage = "你好啊"; 
            mqMessage = new MQMessage();   
            mqMessage.format = MQC.MQFMT_STRING;   
//            mqMessage.write(putMessage.getBytes()); 
            mqMessage.writeUTF(putMessage);
            mqQueue.put(mqMessage, mqPutMessageOptions); 
        } catch (MQException e) {   
            e.printStackTrace();   
        } catch (IOException e1) {   
            e1.printStackTrace();   
        } finally {   
            if (mqQueue != null) {   
                try {   
                    mqQueue.close();   
                } catch (MQException e) {   
                    e.printStackTrace();   
                }   
            }   
            if (mqQueueManager != null) {   
                try {   
                    mqQueueManager.close();   
                } catch (MQException e) {   
                    e.printStackTrace();   
                }   
            }   
        }   
    } 

    public static void main(String arg[]) {   
        MQSender client = new MQSender();   
        Thread mqClientThread = new Thread(client);   
        mqClientThread.start();   
    }   
}