SpringBoot整合ActiveMQ

（1）、添加starter依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>

（2）、配置相关信息

spring.activemq.broker-url=tcp://192.168.205.128:61616
spring.activemq.user=admin
spring.activemq.password=admin

（3）、配置类

package cn.coreqi.config;

import cn.coreqi.entities.User;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
import org.springframework.jms.support.converter.MessageConverter;
import org.springframework.jms.support.converter.MessageType;

import java.util.HashMap;
import java.util.Map;

@Configuration
public class ActivemqConfig {
    //声明一个队列
    @Bean
    public ActiveMQQueue queue(){
        return new ActiveMQQueue("userQueue");
    }
    //声明一个主题
    @Bean
    public ActiveMQTopic topic(){
        return new ActiveMQTopic("userTopic");
    }
    //使用json进行消息的序列化
    @Bean
    public MessageConverter messageConverter(){
        //return new SimpleMessageConverter();  默认
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setTargetType(MessageType.TEXT);
        // 定义了typeId到Class的Map
        Map<String, Class<?>> typeIdMap = new HashMap<>();
        typeIdMap.put("User", User.class);
        converter.setTypeIdMappings(typeIdMap);
        // 设置发送到队列中的typeId的名称
        converter.setTypeIdPropertyName("User");
        converter.setEncoding("UTF-8");
        return converter;
    }
}

（4）、主程序类使用@EnableJms注解开启基于注解的Jms模式

package cn.coreqi;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.jms.annotation.EnableJms;

@SpringBootApplication
@EnableJms
public class SpringbootactivemqApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootactivemqApplication.class, args);
    }

}

（5）、使用JmsTemplate发送和接收消息

    @Autowired
    private JmsOperations jmsOperations;
    public String send(){
//        jmsOperations.send("userQueue", new MessageCreator() {
//            @Override
//            public Message createMessage(Session session) throws JMSException {
//                return session.createObjectMessage(new User(1,"fanqi","fanqisoft",1));
//            }
//        });
        jmsOperations.convertAndSend("userQueue",new User(2,"fanqi","fanqisoft",1));
        return "success";
    }
    public User receive() throws JMSException {
        return (User)jmsOperations.receiveAndConvert("userQueue");
    }

（6）、在service层所需方法上添加@JmsListener注解用于监听队列，当队列中新添加了消息那么此方法将会被调用。

package cn.coreqi.service;

import cn.coreqi.entities.User;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;

@Service
public class UserService {
    @JmsListener(destination = "userQueue")
    public void receive(User user){
        System.out.println(user.toString());
    }
}