ActiveMQ

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);
    }
}

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.config.JmsListenerContainerFactory;
import org.springframework.jms.config.SimpleJmsListenerContainerFactory;
import org.springframework.jms.core.JmsMessagingTemplate;
import javax.jms.ConnectionFactory;
import javax.jms.Queue;
import javax.jms.Topic;

@Configuration
public class BeanConfig {

    @Value("${spring.activemq.broker-url}")
    private String brokerUrl;

    @Value("${spring.activemq.user}")
    private String username;

    @Value("${spring.activemq.topic-name}")
    private String password;

    @Value("${spring.activemq.queue-name}")
    private String queueName;

    @Value("${spring.activemq.topic-name}")
    private String topicName;

    @Bean(name = "queue")
    public Queue queue() {
        return new ActiveMQQueue(queueName);
    }

    //如果有多个queue主题，则继续增加@Bean, @Bean内的name可省略,省略后name为方法名（"queue2"），
    //注意: 后续@Autowired注解“public Queue queue2;”的变量名为此处的name("queue2");
    //队列名称为"queueName2", 后续的队列消费时destination要和此队列名称一致。
    @Bean(name = "queue2")
    public Queue queue2() {
        return new ActiveMQQueue("queueName2");
    }

    //其他的queue主题定义
    //...

    @Bean(name = "topic")
    public Topic topic() {
        return new ActiveMQTopic(topicName);
    }

    @Bean(name = "topic2")
    public Topic topic2() {
        return new ActiveMQTopic("topicName2");
    }

    //其他的topic主题定义
    //...

    @Bean
    public ConnectionFactory connectionFactory(){
        return new ActiveMQConnectionFactory(username, password, brokerUrl);
    }

    @Bean
    public JmsMessagingTemplate jmsMessageTemplate(){
        return new JmsMessagingTemplate(connectionFactory());
    }

    // 在Queue模式中，对消息的监听需要对containerFactory进行配置
    @Bean("queueListener")
    public JmsListenerContainerFactory<?> queueJmsListenerContainerFactory(ConnectionFactory connectionFactory){
        SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setPubSubDomain(false);
        return factory;
    }

    //在Topic模式中，对消息的监听需要对containerFactory进行配置
    @Bean("topicListener")
    public JmsListenerContainerFactory<?> topicJmsListenerContainerFactory(ConnectionFactory connectionFactory){
        SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setPubSubDomain(true);
        return factory;
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.jms.Destination;
import javax.jms.Queue;
import javax.jms.Topic;

@RestController
public class ProducerController{

	@Autowired
	private JmsMessagingTemplate jmsMessagingTemplate;

	@Autowired
	private Queue queue;

	@Autowired
	private Queue queue2;

	//更多的Queue...
	@Autowired
	private Topic topic;

	//更多的topic...

	@PostMapping("/queue/test")
	public String sendQueue(@RequestBody String str) {
		this.sendMessage(this.queue, str);
		return "success";
	}

	@PostMapping("/queue2/test")
	public String sendQueue(@RequestBody String str) {
		this.sendMessage(this.queue2, str);
		return "queue2 success";
	}

	@PostMapping("/topic/test")
	public String sendTopic(@RequestBody String str) {
		this.sendMessage(this.topic, str);
		return "success";
	}

	// 发送消息，destination是发送到的队列，message是待发送的消息
	private void sendMessage(Destination destination, final String message){
		jmsMessagingTemplate.convertAndSend(destination, message);
	}

}

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class QueueConsumerListener{

	//queue模式的消费者
	@JmsListener(destination="${spring.activemq.queue-name}", containerFactory="queueListener")
	public void readActiveQueue(String message) {
		System.out.println("queue接受到：" + message);
	}

	//queue2模式的消费者,
	//destination为queue主题，和ActiveMQBeanConfig定义中的@Bean中的"new ActiveMQQueue("queueName2");"的
	@JmsListener(destination="queueName2", containerFactory="queueListener")
	public void readActiveQueue(String message) {
		System.out.println("queue2接受到：" + message);
	}

	//更多的queue模式的消费者。。。

}

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class TopicConsumerListener{

	//topic模式的消费者
	@JmsListener(destination="${spring.activemq.topic-name}", containerFactory="topicListener")
	public void readActiveQueue(String message) {
		System.out.println("topic接受到：" + message);
	}

	//其他的topic模式的消费者。。。

}

import java.io.Serializable;
import java.util.Date;

public class Message implements Serializable {

    private String content;
    private Date date;

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public Date getDate() {
        return date;
    }

    public void setDate(Date date) {
        this.date = date;
    }

    @Override
    public String toString() {
        return "Message{" +
        "content='" + content + '\'' +
        ", date=" + date +
        '}';
    }
}

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

import javax.jms.Queue;

@SpringBootApplication
public class JmsApplication {

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

    @Bean
    Queue queue() {
        return new ActiveMQQueue("yl-queue");
    }

}

import com.yl.jms.model.Message;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.jms.Queue;

@Component
public class JmsComponent {

    //消息发送模板
    @Autowired
    JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    Queue queue;

    //发送消息
    public void send(Message message) {
        jmsMessagingTemplate.convertAndSend(queue,message);
    }

    //接收消息
    @JmsListener(destination = "yl-queue")
    public void receive(Message message) {
        System.out.println("message:" + message);
    }
}