-
引入pom
<!--rabbitmq--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>
-
配置 application.properties
## rabbitmq 配置(必須) spring.rabbitmq.host=192.168.63.112 spring.rabbitmq.port=5672 spring.rabbitmq.username=admin spring.rabbitmq.password=admin spring.rabbitmq.virtual-host=light_test ## 隊(duì)列名稱 spring.application.name=rabbitmq-provider spring.rabbitmq.exchageName=light_exchange spring.rabbitmq.queueName1=light_queue1 ## 項(xiàng)目端口 server.port=80
-
配置queue和exchage
import org.springframework.amqp.core.*; import org.springframework.beans.factory.annotation.Configurable; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; /** * @Classname RabbitMQConfig * @Description TODO * @Date 2020/7/7 14:23 * @Created by light */ @Configurable public class RabbitMQConfig { @Value("${spring.rabbitmq.exchageName}") private String exchangeName; @Value("${spring.rabbitmq.queueName1}") private String queueName1; /** * 配置 exchange * * @return */ @Bean public DirectExchange exchange() { return new DirectExchange(exchangeName, true, false); } /** * 配置 Queue1 * * @return */ @Bean public Queue lightQueue1() { return new Queue(queueName1, true); } /** * 綁定 指定的queue 到指定的 exchage 上 * @return */ @Bean public Binding bindingQueue1() { return BindingBuilder.bind(lightQueue1()) .to(exchange()) .with(queueName1); } }
-
配置消費(fèi)者
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; import java.util.Map; /** * @Classname RabbitMQConsumer * @Description TODO * @Date 2020/7/7 15:30 * @Created by light */ @Component @RabbitListener(queues = "light_queue1") public class RabbitMQConsumer { /** * 此方法為消費(fèi)方法 * @param messageMap 參數(shù)為發(fā)送消息的 參數(shù) */ @RabbitHandler public void process (Map messageMap) { System.out.println(messageMap.toString()); } }
-
發(fā)送消息
@Resource private RabbitTemplate rabbitTemplate; /** * 發(fā)送消息的方法 */ public void sendMq () { HashMap<String, String> map = new HashMap<>(); map.put("name","light"); map.put("id","1"); map.put("type","1"); rabbitTemplate.convertAndSend(exchateName,queueName1,map); System.out.println("發(fā)送成功"); }
springboot集成 rabbitMQ
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
- 文/潘曉璐 我一進(jìn)店門习寸,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人傻工,你說我怎么就攤上這事霞溪。” “怎么了中捆?”我有些...
- 文/不壞的土叔 我叫張陵鸯匹,是天一觀的道長。 經(jīng)常有香客問我轨香,道長忽你,這世上最難降的妖魔是什么? 我笑而不...
- 正文 為了忘掉前任臂容,我火速辦了婚禮科雳,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘脓杉。我一直安慰自己糟秘,他們只是感情好,可當(dāng)我...
- 文/花漫 我一把揭開白布球散。 她就那樣靜靜地躺著尿赚,像睡著了一般。 火紅的嫁衣襯著肌膚如雪蕉堰。 梳的紋絲不亂的頭發(fā)上凌净,一...
- 文/蒼蘭香墨 我猛地睜開眼乐疆,長吁一口氣:“原來是場噩夢啊……” “哼划乖!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起挤土,我...
- 序言:老撾萬榮一對情侶失蹤琴庵,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體细卧,經(jīng)...
- 正文 獨(dú)居荒郊野嶺守林人離奇死亡尉桩,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
- 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了贪庙。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
- 正文 年R本政府宣布,位于F島的核電站埃唯,受9級特大地震影響撩匕,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜墨叛,卻給世界環(huán)境...
- 文/蒙蒙 一止毕、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧漠趁,春花似錦扁凛、人聲如沸。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至甥绿,卻和暖如春字币,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背共缕。 一陣腳步聲響...
- 正文 我出身青樓共苛,卻偏偏與公主長得像,于是被迫代替她去往敵國和親蜓萄。 傳聞我的和親對象是個(gè)殘疾皇子隅茎,可洞房花燭夜當(dāng)晚...