activeMq简单的通信程序

首先是发送方：程序代码如下！

package JMStile;

 

import java.io.BufferedReader;

import java.io.InputStreamReader;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.MessageProducer;

import javax.jms.Queue;

import javax.jms.Session;

import javax.jms.TextMessage;

import javax.jms.Topic;

import javax.jms.TopicConnection;

import javax.naming.InitialContext;

import javax.jms.Destination;

 

import org.apache.activemq.ActiveMQConnectionFactory;

/*

 * 

 * 消息的发送方

 * 

 * **/

 

public class Sender {

 

 public void send(){

 

try {

ConnectionFactory connectionFactory=new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER,

     ActiveMQConnectionFactory.DEFAULT_PASSWORD,"tcp://192.168.16.228:61616");

TopicConnection  connection=(TopicConnection)connectionFactory.createConnection();

//创建session

Session session=connection.createSession(true, Session.AUTO_ACKNOWLEDGE);

//设置将消息发送给谁

 Destination destination=session.createQueue("my-queue");

 MessageProducer sender=session.createProducer(destination);

 

TextMessage messagetext=session.createTextMessage("我的第一个MQ发送成功了！！！！！！"+destination);

System.out.println("消息的值："+messagetext.getText());

sender.send(messagetext);

session.commit();

            connection.close();

            System.out.println("发送完毕！!");

} catch (Exception e) {

e.printStackTrace();

System.exit(1);//终止真在运行的JVM，非0的代表异常终止虚拟机

}

 }

public static void main(String[] args) {

// TODO Auto-generated method stub

      new Sender().send();

}

 

}

下面的是接受方的代码： package JMStile; import java.io.BufferedReader; import java.io.InputStreamReader; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageListener; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.naming.InitialContext; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; /*  *   * 消息的接收方  *   * **/ public class Receiver {     private boolean stop=false;      public void receive(){ try {             //创建连接 ConnectionFactory factory=new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD,"tcp://192.168.16.228:61616"); //JMS 客户端到JMS Provider 的连接  TopicConnection connection=(TopicConnection)factory.createConnection(); //创建session,一个接受或发送消息的线程 Session session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //指定消息的目的地    Destination destination=session.createQueue("my-queue"); //消费者，消息的接收者 MessageConsumer receiver=session.createConsumer(destination); connection.start(); while(true){ TextMessage msgMessage=(TextMessage)receiver.receive(1000); System.out.println("接收："+msgMessage); if(msgMessage!=null){ //打印一下消息 System.out.println("收到消息：-------》"+msgMessage.getText()); }else { break; } }             connection.close();             session.close();             System.out.println("接收完毕!"); } catch (Exception e) { e.printStackTrace(); System.exit(1); } }     public static void main(String[] args) { new Receiver().receive(); } } 运行程序： 首先运行一下发送方程序，然后运行接受方，看能能不能接受到消息。能接受到消息说明通信成功！