4、springboot+ activemq｜8月更文挑战

“这是我参与8月更文挑战的第4天，活动详情查看：8月更文挑战”java

1.建立工程

file--> new -->project

spring initializr--> 选择默认的 default --> next

填好项目信息 --> next

到这里项目就搭建完成了。web

打开 application.properties 文件添加 spring.activemq.in-memory=true spring.activemq.pool.enabled=falsespring

spring.activemq.in-memory=true
#是不是内存模式，默认为true.
spring.activemq.pool.enabled=false
#是否建立PooledConnectionFactory，而非ConnectionFactory，默认false
复制代码

#spring.activemq.broker-url=tcp://localhost:61616apache

#指定ActiveMQ broker的URL，默认自动生成. #spring.activemq.password#指定broker的密码. #spring.activemq.user#指定broker的用户.springboot

若是使用外部 mq 开启broker-url 将in-memory设置为falsemarkdown

生产者

import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.jms.MessageNotWriteableException;
import javax.jms.Queue;
import javax.jms.Topic;

/**
 * @author Yang
 * 描述：
 */
@RestController
public class Producer {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;


    @RequestMapping("sendqueue")
    public void sendQueue(String msg) throws MessageNotWriteableException {
        final Queue queue = new ActiveMQQueue("queue");
        jmsMessagingTemplate.convertAndSend(queue, msg);

    }

    @RequestMapping("sendtopic")
    public void sendTopic(String msg) throws MessageNotWriteableException {
        final Topic topic = new ActiveMQTopic("topic");
        jmsMessagingTemplate.convertAndSend(topic, msg);

    }

    @JmsListener(destination = "returnmsg")

    public void returnmsg(String msg) {

        System.out.println("*********" + msg + "*************");
    }


}
复制代码

2.消费者app

@JmsListener(destination="queue) 监听dom

@SendTo("returnmsg")，该注解的意思是将return回的值，再发送的"returnmsg"队列中tcp

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * @author Yang
 * 描述：
 */
@Component
public class Consumer {

    @JmsListener(destination = "queue")
    @SendTo("returnmsg")
    public String receiveQueue(String msg) {
        System.out.println("==============" + msg + "==================");
        return "老铁我收到了"+msg;
    }

    @JmsListener(destination = "topic")
    @SendTo("returnmsg")
    public String receiveTopic(String msg){
        System.out.println("==topic=====" + msg + "=======topic====");
        return "topic"+msg;
    }

    @JmsListener(destination = "topic")
    public void receiveTopic2(String msg){
        System.out.println("==topic2=====" + msg + "=======topic2====");
    }
}
复制代码

启动时添加@EnableJms @EnableJms会启动jms的注解扫描，至关于<jms:annotation-d riven/>oop

@SpringBootApplication
@EnableJms
public class DemoApplication {


   public static void main(String[] args) {

      SpringApplication.run(DemoApplication.class, args);
   }
}
复制代码

队列（queue）：

http://localhost:8080/sendqueue?msg=hello%20mq

测试 topic

须要在 application.properties 添加

spring.jms.pub-sub-domain=true
#若是为True，则是Topic；若是是false或者默认，则是queue。
复制代码

http://localhost:8080/sendtopic?msg=hello%20mq%20topic

springboot+activemq topic与 queue 并存实现方案

1. 打开 application.properties 文件添加 spring.activemq.in-memory=true spring.activemq.pool.enabled=false

spring.activemq.in-memory=true
#是不是内存模式，默认为true.
spring.activemq.pool.enabled=false
#是否建立PooledConnectionFactory，而非ConnectionFactory，默认false
复制代码

二、自定义工厂

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;

import javax.jms.ConnectionFactory;

/**
 * @author Yang
 * 描述：
 */
@Configuration
public class MyContainerFactory {

    /**
     * 主题模式
     * @param connectionFactory
     * @return
     */
    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ConnectionFactory connectionFactory) {
        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
        bean.setPubSubDomain(true);
        bean.setConnectionFactory(connectionFactory);
        return bean;
    }

    /**
     * 队列模式
     * @param connectionFactory
     * @return
     */

    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerQueue(ConnectionFactory  connectionFactory) {
        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
        bean.setConnectionFactory(connectionFactory);
        return bean;
    }
}
复制代码

三、消费者 consumer 添加 @JmsListener(destination="",containerFactory="")

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * @author Yang
 * 描述：
 */
@Component
public class Consumer {

    @JmsListener(destination = "queue",containerFactory ="jmsListenerContainerQueue")
    @SendTo("returnmsg")
    public String receiveQueue(String msg) {
        System.out.println("==============" + msg + "==================");
        return "老铁我收到了"+msg;
    }

    @JmsListener(destination = "queue",containerFactory ="jmsListenerContainerQueue")
    public void receiveQueue2(String msg) {
        System.out.println("======receiveQueue2========" + msg + "=========receiveQueue2=========");
    }


    @JmsListener(destination = "topic",containerFactory ="jmsListenerContainerTopic")
    @SendTo("returnmsg")
    public String receiveTopic(String msg){
        System.out.println("==topic=====" + msg + "=======topic====");
        return "topic"+msg;
    }

    @JmsListener(destination = "topic",containerFactory ="jmsListenerContainerTopic")
    public void receiveTopic2(String msg){
        System.out.println("==topic2=====" + msg + "=======topic2====");
    }
}
复制代码

4.效果：

5.代码下载