Java中间消息件ActiveMQ使用实例

更新时间：2019年11月14日 08:58:07 作者：小鱼吃猫

这篇文章主要介绍了Java中间消息件ActiveMQ使用实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

先来说一说我们为什么要用这个东西啊！

比如，我们现在有这样了个问题要解决：

这样，我们就要用到中间消息间了

然后我们就说一下什么是中间消息间吧。

采用消息传送机制/消息队列的中间件技术，进行数据交流，用在分布式系统的集成。
Java中对Jms有了定义，这是Java消息的统一接口。什么是ActiveMq呢？这是这个接口的一种实现，相当于数据库连接驱动一样，不同厂商有自己不同的实现，我们尽快看怎么用代码实现吧。

消息一共有两种接收和发送形式：点对点和发布定阅模式，也就是“一对一”和“一对多”。

1.导包（maven)：

  <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-client</artifactId>
      <version>5.13.4</version>
    </dependency>

2.开始写类，提供者(发送者)和消费者(接收者)是两个不同的项目,我们先创建普通的maven项目，而不是web项目点对点的方式(消息只能被消费一次，如果同时有多个消费者，谁先抢到就是谁的)

消息提供者

 public static void main(String[] args) throws JMSException {

    //创建连接工厂，这个参数就是自己的activeMQ的地址
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");

    //2.创建连接
    Connection connection = connectionFactory.createConnection();

    //3.启动连接
    connection.start();

    //4.获取session(会话对象)
    /*
    arg0 是否启用事务
    arg1 消息的确认方式 自动确认
     */
    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

    //5.创建一个队列对象,名称
    Queue firstQueue = session.createQueue("firstQueue");

    //6.创建一个消息的生产者对象
//    Destination destination = ;//目标对象
    MessageProducer producer = session.createProducer(firstQueue);

    //7.创建一个消息
    TextMessage textMessage = session.createTextMessage("欢迎来到奇的天喻软件");

    //8.发送消息
    producer.send(textMessage);
    //9.关闭资源
    producer.close();
    session.close();
    connection.close();

  }

消息消费者

前几步是一样的，都是创建连接，只有第6步不一样,创建的是一个消费者

public static void main(String[] args) throws JMSException, IOException {
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");

    //2.创建连接
    Connection connection = connectionFactory.createConnection();

    //3.启动连接
    connection.start();

    //4.获取session(会话对象)
    /*
    arg0 是否启用事务
    arg1 消息的确认方式 自动确认
     */
    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

    //5.创建一个队列对象,名称
    Queue firstQueue = session.createQueue("firstQueue");



    //6.创建消息消费者对象
    MessageConsumer consumer = session.createConsumer(firstQueue);

    //7.设置监听
    consumer.setMessageListener(new MessageListener() {
      @Override
      public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage)message;
        try {
          System.out.println("提取的消息是"+textMessage.getText());
        } catch (JMSException e) {
          e.printStackTrace();
        }
      }
    });

    //8.等待键盘输入
    //目的是为了让程序停止来看效果
    System.in.read();


    //9.关闭资源
    consumer.close();
    session.close();
    connection.close();
  }

发布订阅模式（发布消息后，只有在之前运行的消费者才能收到，消息被任何一个消费者消费后，以后启动的消费者不能消费之前的消息）

消息提供者

 //创建连接工厂
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");

    //2.创建连接
    Connection connection = connectionFactory.createConnection();

    //3.启动连接
    connection.start();

    //4.获取session(会话对象)
    /*
    arg0 是否启用事务
    arg1 消息的确认方式 自动确认
     */
    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

    //5
    Topic topic = session.createTopic("first-topic");


    //6.创建一个消息的生产者对象
//    Destination destination = ;//目标对象
    MessageProducer producer = session.createProducer(topic);

    //7.创建一个消息
    TextMessage textMessage = session.createTextMessage("欢迎来到奇的天喻软件");

    //8.发送消息
    producer.send(textMessage);


    //9.关闭资源
    producer.close();
    session.close();
    connection.close();

消费者

    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");

    //2.创建连接
    Connection connection = connectionFactory.createConnection();

    //3.启动连接
    connection.start();

    //4.获取session(会话对象)
    /*
    arg0 是否启用事务
    arg1 消息的确认方式 自动确认
     */
    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

    //5
    Topic topic = session.createTopic("first-topic");



    //6.创建消息消费者对象
    MessageConsumer consumer = session.createConsumer(topic);

    //7.设置监听
    consumer.setMessageListener(new MessageListener() {
      @Override
      public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage)message;
        try {
          System.out.println("提取的消息是"+textMessage.getText());
        } catch (JMSException e) {
          e.printStackTrace();
        }
      }
    });
    //8.等待键盘输入
    //目的是为了让程序停止来看效果
    System.in.read();
    //9.关闭资源
    consumer.close();
    session.close();
    connection.close();

总结，是不是发现上边代码都很相似，那么完全可以用Spring来管理了啊

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

Java设计模式之命令模式详细解析
这篇文章主要介绍了Java设计模式之命令模式详细解析,命令模式将请求封装成对象,以便使用不同的请求、队列或者日志来参数化其他对象,同时也支持可撤销的操作,需要的朋友可以参考下
2024-01-01
java语言自行实现ULID过程底层原理详解
这篇文章主要为大家介绍了java语言自行实现ULID过程底层原理详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-10-10
Java读取.properties配置文件方法示例
这篇文章主要介绍了Java读取.properties配置文件，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-03-03
Spring Boot 多个定时器冲突问题的解决方法
这篇文章主要介绍了Spring Boot 多个定时器冲突问题的解决方法,实际开发中定时器需要解决多个定时器同时并发的问题，也要解决定时器之间的冲突问题，本文通过问题场景重现给大家介绍的非常详细，需要的朋友参考下吧
2022-05-05
ByteArrayOutputStream简介和使用_动力节点Java学院整理
ByteArrayOutputStream 是字节数组输出流。它继承于OutputStream。这篇文章主要介绍了ByteArrayOutputStream简介和使用,需要的朋友可以参考下
2017-05-05
Java 定时器（Timer,TimerTask）详解及实例代码
这篇文章主要介绍了 Java 定时器（Timer,TimerTask）详解及实例代码的相关资料,需要的朋友可以参考下
2017-01-01
Java Kryo,Protostuff,Hessian序列化方式对比
这篇文章主要介绍了Java Kryo,Protostuff,Hessian序列化方式对比，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下
2022-07-07
java实现登录窗口
这篇文章主要为大家详细介绍了java实现登录窗口，含验证码验证、账户注册等，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-04-04
Java中BigDecimal的加减乘除、比较大小与使用注意事项
对于不需要任何准确计算精度的数字可以直接使用float或double，但是如果需要精确计算的结果，则必须使用BigDecimal类，而且使用BigDecimal类也可以进行大数的操作，下面这篇文章给大家介绍了Java中BigDecimal的加减乘除、比较大小与使用注意事项，需要的朋友可以参考下。
2017-11-11
JavaWeb BeanUtils信息类原理详解
这篇文章主要介绍了JavaWeb BeanUtils信息类原理详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-02-02

Java中间消息件ActiveMQ使用实例

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具