一、整合前的準備

創(chuàng)新互聯(lián)是一家網站設計公司，集創(chuàng)意、互聯(lián)網應用、軟件技術為一體的創(chuàng)意網站建設服務商，主營產品：響應式網站建設、高端網站設計、全網營銷推廣。我們專注企業(yè)品牌在網站中的整體樹立，網絡互動的體驗，以及在手機等移動端的優(yōu)質呈現(xiàn)。成都網站建設、成都網站設計、移動互聯(lián)產品、網絡運營、VI設計、云產品.運維為核心業(yè)務。為用戶提供一站式解決方案，我們深知市場的競爭激烈，認真對待每位客戶，為客戶提供賞析悅目的作品，網站的價值服務。

1.1、安裝windows/linux系統(tǒng)版本的rabbitmq。

1.2、此次整合使用eclipse

二、springboot整合rabbitmq

2.1、pom依賴引入

org.springframework.boot

spring-boot-starter-amqp

2.2、yml配置和configer文件編寫

spring:

rabbitmq:

host: 127.0.0.1

port: 5672

username: xiangjiao

password: bunana

virtual-host: /xiangjiao

#publisher-confirms: true #消息發(fā)送到轉發(fā)器確認機制，是都確認回調

#publisher-returns: true

import org.springframework.amqp.core.Binding;

import org.springframework.amqp.core.BindingBuilder;

import org.springframework.amqp.core.DirectExchange;

import org.springframework.amqp.core.Queue;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class MQConfiguration {

//隊列名稱

public static final String QUEUQ_NAME = "xiangjiao.queue";

//交換器名稱

public static final String EXCHANGE = "xiangjiao.exchange";

//路由key

public static final String ROUTING_KEY = "xiangjiao.routingKey";

//創(chuàng)建隊列

@Bean

public Queue getQueue(){

return new Queue(QUEUQ_NAME);

}

//實例化交換機

@Bean

public DirectExchange getDirectExchange(){

//DirectExchange(String name, boolean durable, boolean autoDelete)

return new DirectExchange(EXCHANGE, true, true);

}

//綁定消息隊列和交換機

@Bean

public Binding bindExchangeAndQueue(DirectExchange exchange,Queue queue){

return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);

}

}

2.3、消息消費者監(jiān)聽創(chuàng)建

import org.springframework.amqp.rabbit.annotation.RabbitListener;

import org.springframework.stereotype.Service;

import cn.linkpower.config.MQConfiguration;

@Service鄭州人流醫(yī)院 http://m.zzzy120.com/

public class MessageConsumerService {

@RabbitListener(queues=MQConfiguration.QUEUQ_NAME)

public void receiveMessage(String msg){

System.err.print("紅色 接收消息----"+String.valueOf(msg));

}

}

2.4、消息生產者

2.4.1、創(chuàng)建消息生產者接口

/**

* 定義消息發(fā)送接口

* @author 765199214

*

*/

public interface IMessageProductService {

public void sendMessage(String msg);

}

2.4.2、創(chuàng)建消息消費者實現(xiàn)類

import org.springframework.amqp.rabbit.core.RabbitTemplate;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import cn.linkpower.config.MQConfiguration;

import cn.linkpower.service.IMessageProductService;

@Service

public class MessageProductServiceImpl implements IMessageProductService {

@Autowired

private RabbitTemplate rabbitTemplate;

@Override

public void sendMessage(String msg) {

rabbitTemplate.convertAndSend(MQConfiguration.EXCHANGE,

MQConfiguration.ROUTING_KEY,

msg);

}

}

2.5、創(chuàng)建控制器

@RequestMapping("/sendMsg2")

@ResponseBody

public String sendMsg2(HttpServletRequest request){

String msg = request.getParameter("msg");

log.info("sendMsg --- msg--"+String.valueOf(msg));

messageProductServiceImpl.sendMessage(msg);

return "send ok";

}

三、測試

控制臺輸出：

網站名稱：springboot整合rabbitmq（Springboot2.X）
鏈接分享：http://chinadenli.net/article2/gddcoc.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供小程序開發(fā)、企業(yè)網站制作、手機網站建設、域名注冊、網站內鏈、外貿建站

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)