QX项目实战-9.ActiveMQ编程实例

按照参考1的配置，ActiveMQ已经可以运行了。但是牵涉到它的架构、部署和运行机制比较复杂，动手编程比较困难。所幸基本的消息收发机制已经可以实现了，所以暂时写一个测试例子来测试下消息传递的功能。

按照参考2所述，本例子采用queue消息的形式，用producerClient来发送消息到ActiveMQ的消息队列，用consumerClient来接收ActiveMQ的消息来显示。producerClient和consumerClient分别调用producerTool.java和consumerTool.java类来实现建立连接、发送和接收消息的功能。

producerTool.java代码如下，注意这里的destination= session.createQueue(queue);代码，此时创建的是队列消息，换成destination= session.createTopic(topic);就是主题消息队列。这里使用的是队列消息机制。代码如下：

      运行结果ConsumerClient收到的消息为：
      PS(2012-11-22)：本例中客户端和服务器代码均运行于ActiveMQ服务器端机器上，生产和消费均在同一IP地址下，测试没有问题。为了保证消息传递，我们采用在服务器端发送消息，客户端接收消息的方法来实现代码。在消费者代码中，我们修改连接URL修改为private String url ="tcp://192.168.195.54:61616";这里192.168.195.54是ActiveMQ服务器地址。上述改写完成后，程序即可实现在服务器端发送消息，在客户端接收消息。
参考
1.      QX项目实战-7.ActiveMQ的安装与测试
2.      QX项目实战-8.ActiveMQ的Queue消息和Topic消息