消息队列 1对1 ActiveMq

Posted ynhk

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了消息队列 1对1 ActiveMq相关的知识,希望对你有一定的参考价值。

依赖===》消息队列核心发送--接收类

依赖:

        <!--消息队列activemq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>

消息队列核心发送--接收类:

package com.test.springboot.util;


import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.jms.Destination;

/**
 * @Company:wftdlx
 * @Author: wjf
 * @Description: 消息队列  1对1
 * @Date: Created in 9:08 2019/5/21
 */
//发送消息 --  接收消息
@Component
public class ActiveMqHandle {

    @Autowired // 也可以注入JmsTemplate,JmsMessagingTemplate对JmsTemplate进行了封装
    JmsMessagingTemplate jmsTemplate;

    // 发送消息:destination是发送到的队列,message是待发送的消息
    public void producerSendMessageMessage(String message) {
        Destination destination = new ActiveMQQueue("destination1");
        jmsTemplate.convertAndSend(destination, message);
    }


    // 接收消息: 使用JmsListener配置消费者监听的队列,其中text是接收到的消息
    @JmsListener(destination = "destination1")
    public void consumerReceiveMessage(String text) throws Exception {
         System.out.println("Consumer收到的报文为:" + text);
    }


}
    
package com.test.springboot;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootJmsActiveMqlicationTests {

    @Autowired
    com.test.springboot.util.ActiveMqHandle ActiveMqHandle;

    @Test
    public void contextLoads() throws InterruptedException {


        for (int i = 0; i < 100; i++) {
            ActiveMqHandle.producerSendMessageMessage("myname is chhliu!!!");
        }
    }

}

  

以上是关于消息队列 1对1 ActiveMq的主要内容,如果未能解决你的问题,请参考以下文章

消息队列-ActiveMQ

使用 C# 和 Apache NMS 的 ActiveMQ - 对队列中的消息进行计数

ActiveMQ消息队列的使用及应用

ActiveMQ消息队列的使用及应用

Spring + JMS + ActiveMQ实现简单的消息队列(监听器异步实现)

ActiveMQ笔记之点对点队列(Point-to-Point)