springboot整合activeMq
ActiveMq是Apache提供的开源音讯零碎采纳java实现，
很好地反对JMS（Java Message Service,即Java音讯服务） 标准
ActiveMq装置：http://activemq.apache.org/co... 在官网下载安装对应的版本
下载实现后解压就能够应用
ActiveMq默认的端口号是8161，用户名和明码都是admin 在本机能够应用http://localhost:8161 去拜访
springboot整合ActiveMq
1、导入依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId></dependency>2、在properties文件中配置activeMq
spring.activemq.broker-url=tcp://localhost:61616#如果是点对点（queue），那么此处默认应该是false，如果公布订阅，那么肯定设置为truespring.activemq.packages.trust-all=truespring.activemq.user=adminspring.activemq.password=admin3、编写queue（队列）
@Componentpublic class QueueBean{ //创立一个队列实例 @Bean Queue queue(){ //这里设置的音讯是队列的名称 return new ActiveMQQueue("hello.javaboy"); }}4、创立音讯的发送者以及消费者
@Componentpublic class JmsComponent{ //springboot提供的音讯模板 @Autowired JmsMessagingTemplate jmsMessagingTemplate; //本人创立的队列实例 @Autowired Queue queue; /** * 发送音讯 * @param message */ public void send(Message message){ jmsMessagingTemplate.convertAndSend(this.queue,message); } /** * 接管音讯 * @param message */ //示意监听该队列名称发来的音讯 @JmsListener(destination = "hello.javaboy") public void readMessage(Message message){ System.out.println(message); }}5、上述Message实体类
public class Message implements Serializable { private String content;//音讯主体 private Date sendDate;//音讯发送的工夫 //省略get、set、tostring办法}6、进行音讯的发送以及生产
在测试类中注入JmsComponent 调用send()办法进行音讯的转发
@SpringBootTestclass ActivemqApplicationTests { @Autowired JmsComponent jmsComponent; @Test void contextLoads() { Message message = new Message(); message.setContent("hello activeMq"); message.setSendDate(new Date()); jmsComponent.send(message); }}首先启动我的项目，在运行测试类进行音讯发送：
控制台会打印消息内容：
springboot整合RabbitMQ
rabbitmq装置比拟繁琐，这里应用docker容器进行装置，docker装置十分不便，一条命令全副搞定
通过docker装置rabbitmq
-P(大p)示意主动映射到主机端口
docker run -d --hostname my-rabbitmq --name some-rabbitmq -P rabbitmq:3-management首先导入依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>编写配置文件：
#配置rabbitMQspring.rabbitmq.host=localhostspring.rabbitmq.username=guestspring.rabbitmq.password=guestspring.rabbitmq.port=32771
RabbitMQ 四种替换模式：
直连交换机：Direct exchange
扇形交换机：Fanout exchange
主体交换机：Topic exchange
首部交换机：Headers exchange
上面别离介绍4中替换模式：
1、Direct exchange
//Direct策略（只转发给routingKey相匹配的用户）@Configurationpublic class RabbitDirectConfig { public final static String DIRECTNAME = "javaboy-direct"; //音讯队列 @Bean Queue queue(){ //name值为队列名称，routingKey会与他进行匹配 return new Queue("hello.RabbitMQ"); } @Bean Queue queue1(){ return new Queue("hello.RabbitMQ1"); } @Bean DirectExchange directExchange(){ //第一个参数为DIRECTNAME、第二个参数示意重启后是否无效，第三参数示意长时间未应用是否删除 return new DirectExchange(DIRECTNAME,true,false); } @Bean Binding binding(){ //将队列queue和DirectExchange绑定在一起 return BindingBuilder.bind(queue()).to(directExchange()).with("direct"); } @Bean Binding binding1(){ //将队列queue和DirectExchange绑定在一起 return BindingBuilder.bind(queue1()).to(directExchange()).with("direct"); }}2、配置消费者DirectReceiver：
//配置消费者@Componentpublic class DirectReceiver { //只监听queue()队列的音讯 @RabbitListener(queues = "hello.RabbitMQ") public void hanlder(String msg){ System.out.println("hanlder>>>"+msg); } //只监听queue1()队列的音讯 @RabbitListener(queues = "hello.RabbitMQ1") public void hanlder1(String msg){ System.out.println("hanlder1>>>"+msg); }}测试代码：
在springboot的测试类中注入RabbitTemplate(springboot提供的RabbitMQ模板)
@Autowired RabbitTemplate rabbitTemplate; @Test void contextLoads() { //两个参数第一个是routingKey、第二个为音讯内容 rabbitTemplate.convertAndSend("hello.RabbitMQ","hello RabbitMQ test"); rabbitTemplate.convertAndSend("hello.RabbitMQ1","hello RabbitMQ test222"); }启动我的项目后，运行测试类能够看到只有与routingkey相匹配的消费者受到了对应的音讯：
2、Fanout exchange
Fanout策略（只有是与他绑定的队列，都会收到音讯与routingKey无关）
1、配置RabbitFanoutConfig：
//Fanout策略（只有是与他绑定的队列，都会收到音讯与routingKey无关）@Configurationpublic class RabbitFanoutConfig { public final static String FANOUTNAME = "javaboy-fanout"; //配置了两个音讯队列queueOne和queueTwo @Bean Queue queueOne(){ return new Queue("queue-one"); } @Bean Queue queueTwo(){ return new Queue("queue-two"); } @Bean FanoutExchange fanoutExchange(){ return new FanoutExchange(FANOUTNAME,true,false); } //将两个队列与FanoutExchange绑定 @Bean Binding bindingOne(){ return BindingBuilder.bind(queueOne()).to(fanoutExchange()); } @Bean Binding bindingTwo(){ return BindingBuilder.bind(queueTwo()).to(fanoutExchange()); }}2、配置消费者FanoutReceiver：
//配置消费者@Componentpublic class FanoutReceiver { //两个消费者别离监听两个不同的队列 @RabbitListener(queues = "queue-one") public void hanlder1(String msg){ System.out.println("FanoutReceiver:hanlder1>>>"+msg); } @RabbitListener(queues = "queue-two") public void hanlder2(String msg){ System.out.println("FanoutReceiver:hanlder2>>>"+msg); }}3、测试类：
@Test void rabbitFanout(){ //三个参数示意RabbitFanoutConfig的名称、routingkey、音讯内容 rabbitTemplate.convertAndSend(RabbitFanoutConfig.FANOUTNAME,null,"hello fanout test"); }该形式与routingkey无关所有写null即可
查看输入：能够看到两个消费者都收到了音讯
3、Topic exchange
topic策略能够依据routingKey的规定（通配符形式）进行去匹配队列进行转发规定为.#. *为单词，#示意含糊匹配
例如routingkey为：xiaomi.# 那么带有xiaomi.结尾的队列都会收到该音讯
routingkey为：#.phone.# 示意音讯的routingKey中带有phone时 就会去匹配带有phone的队列
1、配置RabbitTopicConfig：
/topic策略能够依据routingKey的规定（通配符形式）进行去匹配队列进行转发规定为*.#.* //*为单词，#示意含糊匹配@Configurationpublic class RabbitTopicConfig { public final static String TOPICNAME = "javaboy-topic"; @Bean TopicExchange topicExchange(){ return new TopicExchange(TOPICNAME,true,false); } @Bean Queue xiaomi(){ return new Queue("xiaomi"); } @Bean Queue huawei(){ return new Queue("huawei"); } @Bean Queue phone(){ return new Queue("phone"); } @Bean Binding xiaomiBinding(){ //xiaomi.#：示意音讯的routingKey是以xiaomi结尾的就会路由到xiaomi的队列 return BindingBuilder.bind(xiaomi()).to(topicExchange()).with("xiaomi.#"); } @Bean Binding huaweiBinding(){ return BindingBuilder.bind(huawei()).to(topicExchange()).with("huawei.#"); } @Bean Binding phoneBinding(){ //#.phone.#：示意音讯的routingKey中带phone的都会路由到phone的队列 return BindingBuilder.bind(phone()).to(topicExchange()).with("#.phone.#"); }}2、配置消费者TopicReceiver：
@Componentpublic class TopicReceiver { //别离监听名称为xiaomi、huawei、phone的队列 @RabbitListener(queues = "xiaomi") public void handlerXM(String msg){ System.out.println("TopicReceiver:handlerXM>>>"+msg); } @RabbitListener(queues = "huawei") public void handlerHW(String msg){ System.out.println("TopicReceiver:handlerHW>>>"+msg); } @RabbitListener(queues = "phone") public void handlerPHONE(String msg){ System.out.println("TopicReceiver:handlerPHONE>>>"+msg); }}3、测试类：
@Test void rabbitTopic(){ //依据匹配规定该音讯只能被xiaomi的队列收到 rabbitTemplate.convertAndSend(RabbitTopicConfig.TOPICNAME,"xiaomi.news","小米新闻"); //依据匹配规定该音讯只能被phone的队列收到 rabbitTemplate.convertAndSend(RabbitTopicConfig.TOPICNAME,"vivo.phone","vivo手机"); //依据匹配规定该音讯能够别huawei和phone两个队列收到 rabbitTemplate.convertAndSend(RabbitTopicConfig.TOPICNAME,"huawei.phone","华为手机"); }查看输入：
能够看到routingkey为huawei.phone的音讯匹配了两个队列，其余两个都只匹配了一个队列
4、Headers exchange
该模式是依据路由规定的header进行匹配的，在进行匹配的时候须要传入一个map汇合，routingkey去匹配map即可中的key value，匹配规定能够使any或者all，any示意只有蕴含任意信息就能够，all示意所有信息都必须匹配
1、配置RabbitHeaderConfig：
@Configurationpublic class RabbitHeaderConfig { public final static String HEADERNAME = "javaboy-header"; @Bean HeadersExchange headersExchange(){ return new HeadersExchange(HEADERNAME,true,false); } //别离创立两个不同header的队列 @Bean Queue queueName(){ return new Queue("name-queue"); } @Bean Queue queueAge(){ return new Queue("age-queue"); } @Bean Binding bindingName(){ Map<String,Object> map = new HashMap<>(); map.put("name","hello"); //示意如果routingKey匹配的map汇合中的key value 就会将音讯转发到对应的路由上 return BindingBuilder.bind(queueName()).to(headersExchange()).whereAny(map).match(); } @Bean Binding bindingAge(){ return BindingBuilder.bind(queueAge()).to(headersExchange()).where("age").exists(); }}2、创立消费者HeaderReceiver:
@Componentpublic class HeaderReceiver { @RabbitListener(queues = "name-queue") public void handlerName(byte[] msg){ System.out.println("HeaderReceiver:handlerName>>>>"+new String(msg,0,msg.length)); } @RabbitListener(queues = "age-queue") public void handlerAge(byte[] msg){ System.out.println("HeaderReceiver:handlerAge>>>>"+new String(msg,0,msg.length)); }}3、测试代码：
@Test public void rabbitHeader(){ //设置音讯，并且设置header，setHeader("name","hello")别离示意map汇合中的key、value Message nameMessage = MessageBuilder.withBody("hello name".getBytes()).setHeader("name","hello").build(); Message ageMessage = MessageBuilder.withBody("hello 99 age".getBytes()).setHeader("age","99").build(); rabbitTemplate.send(RabbitHeaderConfig.HEADERNAME,null,nameMessage); rabbitTemplate.send(RabbitHeaderConfig.HEADERNAME,null,ageMessage); }查看输入：
扭转setheader中的值查看后果：
Message nameMessage = MessageBuilder.withBody("hello name".getBytes()).setHeader("name","javaboy").build();
能够看到因为key、value匹配不上只打印了一条音讯。
最初
大家看完有什么不懂的能够在下方留言探讨，也能够关注我私信问我，我看到后都会答复的。也欢送大家关注我的公众号：前程有光，金三银四跳槽面试季，整顿了1000多道将近500多页pdf文档的Java面试题材料，文章都会在外面更新，整顿的材料也会放在外面。谢谢你的观看，感觉文章对你有帮忙的话记得关注我点个赞反对一下！