基本概念：

---

---

接收者：

---

1. package com.ll.activemq;
3. import java.util.Collection;
4. import java.util.Iterator;
6. import javax.jms.Connection;
7. import javax.jms.ConnectionFactory;
8. import javax.jms.Destination;
9. import javax.jms.MapMessage;
10. import javax.jms.MessageConsumer;
11. import javax.jms.Session;
12. import javax.jms.TextMessage;
13. import org.apache.activemq.ActiveMQConnection;
14. import org.apache.activemq.ActiveMQConnectionFactory;
16. public class Receiver {
17. public static void main(String[] args) {
18. // ConnectionFactory ：连接工厂，JMS 用它创建连接
19. ConnectionFactory connectionFactory;
20. // Connection ：JMS 客户端到JMS Provider 的连接
21. Connection connection = null;
22. // Session： 一个发送或接收消息的线程
23. Session session;
24. // Destination ：消息的目的地;消息发送给谁.
25. Destination destination;
26. // 消费者，消息接收者
27. MessageConsumer consumer;
28. connectionFactory = new ActiveMQConnectionFactory(
29. ActiveMQConnection.DEFAULT_USER,
30. ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
31. try {
32. // 构造从工厂得到连接对象
33. connection = connectionFactory.createConnection();
34. // 启动
35. connection.start();
36. // 获取操作连接
37. session = connection.createSession(Boolean.FALSE,
38. Session.AUTO_ACKNOWLEDGE);
39. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置
40. destination = session.createQueue("FirstQueue");
41. consumer = session.createConsumer(destination);
42. // consumer2 = session.createConsumer(destination);
43. while (true) {
44. // 设置接收者接收消息的时间，为了便于测试，这里谁定为100s
45. TextMessage message = (TextMessage) consumer.receive(28000);
46. // Object message = (Object) consumer.receive(28000);
47. if (null != message) {
48. System.out.println("收到消息" + message.getText());
49. } else {
50. System.out.println("时间到...\n");
51. break;
52. }
53. }
54. } catch (Exception e) {
55. e.printStackTrace();
56. } finally {
57. try {
58. if (null != connection)
59. connection.close();
60. } catch (Throwable ignore) {
61. }
62. }
63. }
64. }

---

发送者：

---

1. package com.ll.activemq;
3. import java.util.Collection;
4. import java.util.Iterator;
6. import javax.jms.Connection;
7. import javax.jms.ConnectionFactory;
8. import javax.jms.Destination;
9. import javax.jms.MapMessage;
10. import javax.jms.MessageConsumer;
11. import javax.jms.Session;
12. import javax.jms.TextMessage;
13. import org.apache.activemq.ActiveMQConnection;
14. import org.apache.activemq.ActiveMQConnectionFactory;
16. public class Receiver {
17. public static void main(String[] args) {
18. // ConnectionFactory ：连接工厂，JMS 用它创建连接
19. ConnectionFactory connectionFactory;
20. // Connection ：JMS 客户端到JMS Provider 的连接
21. Connection connection = null;
22. // Session： 一个发送或接收消息的线程
23. Session session;
24. // Destination ：消息的目的地;消息发送给谁.
25. Destination destination;
26. // 消费者，消息接收者
27. MessageConsumer consumer;
28. connectionFactory = new ActiveMQConnectionFactory(
29. ActiveMQConnection.DEFAULT_USER,
30. ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
31. try {
32. // 构造从工厂得到连接对象
33. connection = connectionFactory.createConnection();
34. // 启动
35. connection.start();
36. // 获取操作连接
37. session = connection.createSession(Boolean.FALSE,
38. Session.AUTO_ACKNOWLEDGE);
39. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置
40. destination = session.createQueue("FirstQueue");
41. consumer = session.createConsumer(destination);
42. // consumer2 = session.createConsumer(destination);
43. while (true) {
44. // 设置接收者接收消息的时间，为了便于测试，这里谁定为100s
45. TextMessage message = (TextMessage) consumer.receive(28000);
46. // Object message = (Object) consumer.receive(28000);
47. if (null != message) {
48. System.out.println("收到消息" + message.getText());
49. } else {
50. System.out.println("时间到...\n");
51. break;
52. }
53. }
54. } catch (Exception e) {
55. e.printStackTrace();
56. } finally {
57. try {
58. if (null != connection)
59. connection.close();
60. } catch (Throwable ignore) {
61. }
62. }
63. }
64. }

---