Java消息机制 ActiveMQ入门实例

2022-04-16 15:16:23

转载自：http://www.cnblogs.com/wyh3721/p/5917316.html

1.下载ActiveMQ

去官方网站下载：http://activemq.apache.org/ 
我下载的时候是 ActiveMQ 5.14.0 Release版

2.运行ActiveMQ

解压缩apache-activemq-5.14.0-bin.zip，然后双击apache-activemq-5.14.0-bin\apache-activemq-5.14.0\bin\win64\activemq.bat运行ActiveMQ程序。 
启动ActiveMQ以后，登陆：http://localhost:8161/admin/，创建一个Queue，命名为FirstQueue。

3.创建Eclipse项目并运行

创建java project：ActiveMQ-5.14，新建lib文件夹 
打开apache-activemq-5.14.0-bin\apache-activemq-5.14.0\lib目录 
拷贝如下6个jar包：

activemq-broker-5.14.0.jar

activemq-client-5.14.0.jar

activemq-all-5.14.0.jar

geronimo-j2ee-management_1.1_spec-1.0.1.jar

geronimo-jms_1.1_spec-1.1.1.jar

slf4j-api-1.7.13.jar

这6个jar文件到lib文件夹中,并Build Path->Add to Build Path

结构如图:

Java消息机制 ActiveMQ入门实例

4、示例代码

Sender.java ：



    

  1. package test;
    2. 

  2. import javax.jms.Connection;
    3. 

  3. import javax.jms.ConnectionFactory;
    4. 

  4. import javax.jms.DeliveryMode;
    5. 

  5. import javax.jms.Destination;
    6. 

  6. import javax.jms.MessageProducer;
    7. 

  7. import javax.jms.Session;
    8. 

  8. import javax.jms.TextMessage;
    9. 

  9. import org.apache.activemq.ActiveMQConnection;
    10. 

  10. import org.apache.activemq.ActiveMQConnectionFactory;
    11. 

  11. publicclassSender{
    12. 

  12. privatestaticfinalint SEND_NUMBER =5;
    13. 

  13. publicstaticvoid main(String[] args){
    14. 

  14. ConnectionFactory connectionFactory;// ConnectionFactory--连接工厂，JMS用它创建连接
    15. 

  15. // Provider 的连接
    16. 

  16. Connection connection =null;// Connection ：JMS 客户端到JMS
    17. 

  17. Session session;// Session： 一个发送或接收消息的线程
    18. 

  18. Destination destination;// Destination ：消息的目的地;消息发送给谁.
    19. 

  19. MessageProducer producer;// MessageProducer：消息发送者
    20. 

  20. // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar
    21. 

  21. connectionFactory =newActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
    22. 

  22. ActiveMQConnection.DEFAULT_PASSWORD,"tcp://localhost:61616");
    23. 

  23. try{// 构造从工厂得到连接对象
    24. 

  24. connection = connectionFactory.createConnection();
    25. 

  25. // 启动
    26. 

  26. connection.start();
    27. 

  27. // 获取操作连接
    28. 

  28. session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE);
    29. 

  29. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置
    30. 

  30. destination = session.createQueue("FirstQueue");
    31. 

  31. // 得到消息生成者【发送者】
    32. 

  32. producer = session.createProducer(destination);
    33. 

  33. // 设置不持久化，此处学习，实际根据项目决定
    34. 

  34. producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
    35. 

  35. // 构造消息，此处写死，项目就是参数，或者方法获取
    36. 

  36. sendMessage(session, producer);
    37. 

  37. session.commit();
    38. 

  38. }catch(Exception e){
    39. 

  39. e.printStackTrace();
    40. 

  40. }finally{
    41. 

  41. try{
    42. 

  42. if(null!= connection)
    43. 

  43. connection.close();
    44. 

  44. }catch(Throwable ignore){
    45. 

  45. }
    46. 

  46. }
    47. 

  47. }
    48. 

  48. publicstaticvoid sendMessage(Session session,MessageProducer producer)throwsException{
    49. 

  49. for(int i =1; i <= SEND_NUMBER; i++){
    50. 

  50. TextMessage message = session.createTextMessage("ActiveMq 发送的消息"+ i);
    51. 

  51. // 发送消息到目的地方
    52. 

  52. System.out.println("发送消息："+"ActiveMq 发送的消息"+ i);
    53. 

  53. producer.send(message);
    54. 

  54. }
    55. 

  55. }
    56. 

  56. }
    57. 





Receiver.java ：






    

  1. package test;
    2. 

  2. import javax.jms.Connection;
    3. 

  3. import javax.jms.ConnectionFactory;
    4. 

  4. import javax.jms.Destination;
    5. 

  5. import javax.jms.MessageConsumer;
    6. 

  6. import javax.jms.Session;
    7. 

  7. import javax.jms.TextMessage;
    8. 

  8. import org.apache.activemq.ActiveMQConnection;
    9. 

  9. import org.apache.activemq.ActiveMQConnectionFactory;
    10. 

  10. public class Receiver {
    11. 

  11. public static void main(String[] args) {
    12. 

  12. // ConnectionFactory ：连接工厂，JMS 用它创建连接
    13. 

  13. ConnectionFactory connectionFactory;
    14. 

  14. // Connection ：JMS 客户端到JMS Provider 的连接
    15. 

  15. Connection connection = null;
    16. 

  16. // Session： 一个发送或接收消息的线程
    17. 

  17. Session session;
    18. 

  18. // Destination ：消息的目的地;消息发送给谁.
    19. 

  19. Destination destination;
    20. 

  20. // 消费者，消息接收者
    21. 

  21. MessageConsumer consumer;
    22. 

  22. connectionFactory = new ActiveMQConnectionFactory(
    23. 

  23. ActiveMQConnection.DEFAULT_USER,
    24. 

  24. ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
    25. 

  25. try {
    26. 

  26. // 构造从工厂得到连接对象
    27. 

  27. connection = connectionFactory.createConnection();
    28. 

  28. // 启动
    29. 

  29. connection.start();
    30. 

  30. // 获取操作连接
    31. 

  31. session = connection.createSession(Boolean.FALSE,
    32. 

  32. Session.AUTO_ACKNOWLEDGE);
    33. 

  33. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置
    34. 

  34. destination = session.createQueue("FirstQueue");
    35. 

  35. consumer = session.createConsumer(destination);
    36. 

  36. while (true) {
    37. 

  37. // 设置接收者接收消息的时间，为了便于测试，这里谁定为100s
    38. 

  38. TextMessage message = (TextMessage) consumer.receive(500000);
    39. 

  39. if (null != message) {
    40. 

  40. System.out.println("收到消息" + message.getText());
    41. 

  41. } else {
    42. 

  42. break;
    43. 

  43. }
    44. 

  44. }
    45. 

  45. } catch (Exception e) {
    46. 

  46. e.printStackTrace();
    47. 

  47. } finally {
    48. 

  48. try {
    49. 

  49. if (null != connection)
    50. 

  50. connection.close();
    51. 

  51. } catch (Throwable ignore) {
    52. 

  52. }
    53. 

  53. }
    54. 

  54. }
    55. 

  55. }
    56. 





5.测试过程


先运行:Receiver.java 

再运行:Sender.java


可以看到结果 

Sender运行后:




    

  1. 发送消息：ActiveMq发送的消息1
    2. 

  2. 发送消息：ActiveMq发送的消息2
    3. 

  3. 发送消息：ActiveMq发送的消息3
    4. 

  4. 发送消息：ActiveMq发送的消息4
    5. 

  5. 发送消息：ActiveMq发送的消息5​
    6. 



Receiver运行后:




    

  1. 收到消息ActiveMq发送的消息1
    2. 

  2. 收到消息ActiveMq发送的消息2
    3. 

  3. 收到消息ActiveMq发送的消息3
    4. 

  4. 收到消息ActiveMq发送的消息4
    5. 

  5. 收到消息ActiveMq发送的消息5​
    6. 



要想看到不同的输出内容,通过点击如下图的按钮切换console


Java消息机制 ActiveMQ入门实例


上一篇：iOS开发——判断手机格式

下一篇：hadoop学习大纲