springboot使用消息中間件

更新時(shí)間：2019年10月21日 14:17:38 作者：三鮮豆皮

這篇文章主要介紹了springboot使用消息中間件,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

前言

使用SpringBoot集成rabbitmq實(shí)現(xiàn)一個(gè)發(fā)送和接收

內(nèi)容

1.引入依賴

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

2.application.properties

#rabbitmq配置
spring.application.name=springboot-mq
spring.rabbitmq.host=192.168.17.129
spring.rabbitmq.port=5672
spring.rabbitmq.username=mytest
spring.rabbitmq.password=mytest

3.rabbitmap配置類

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

 @Bean
 public Queue mqQueue(){
  return new Queue("mqboot");
 }
}

4.發(fā)送類< 大專欄 zyzx(53)-springboot使用消息中間件/h5>

@Component
public class Sender {

 @Autowired
 private AmqpTemplate rabbitTemplate;

 public void send(){
  String content = "send: hello"+new Date();
  System.out.println("Sender:"+content)
  this.rabbitTemplate.convertAndSend("mqboot",content);
 }
}

收類

@Component
@RabbitListener(queues = "mqboot")
public class Receiver {

 @RabbitHandler
 public void process(String data){
  System.out.println("Receiver:"+data);
 }
}

6.測(cè)試

啟動(dòng)springBoot

如下顯示表明:連接成功:

@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {
 @Autowired
 private TeacherRepository teacherRepository;

 /*@Autowired
 private JavaMailSender javaMailSender;*/

 @Autowired
 private Sender sender;

 @Test
 public void contextLoads() {
  //mq測(cè)試
  sender.send();
 }
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

Java?properties?和?yml?的區(qū)別解析
properties和yml都是Spring?Boot支持的兩種配置文件，它們可以看做Spring?Boot在不同時(shí)期的兩種“產(chǎn)品”，這篇文章主要介紹了Java?properties?和?yml?的區(qū)別,需要的朋友可以參考下
2023-02-02
break在scala和java中的區(qū)別解析
這篇文章主要介紹了break在scala和java中的區(qū)別解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2019-11-11
JPA設(shè)置默認(rèn)字段及其長(zhǎng)度詳解
JPA是Java Persistence API的簡(jiǎn)稱，中文名Java持久層API，是JDK 5.0注解或XML描述對(duì)象－關(guān)系表的映射關(guān)系，并將運(yùn)行期的實(shí)體對(duì)象持久化到數(shù)據(jù)庫(kù)中。本文主要介紹了JPA如何設(shè)置默認(rèn)字段及其長(zhǎng)度，感興趣的同學(xué)可以了解一下
2021-12-12
MyBatisPlus的簡(jiǎn)介及案例詳解
MyBatisPlus（簡(jiǎn)稱MP）是基于MyBatis框架基礎(chǔ)上開(kāi)發(fā)的增強(qiáng)型工具，旨在簡(jiǎn)化開(kāi)發(fā)、提高效率。本文將為大家詳細(xì)介紹一下MyBatisPlus是使用，需要的可以參考一下
2022-07-07
Java利用future及時(shí)獲取多線程運(yùn)行結(jié)果
在Java編程中，有時(shí)候會(huì)需要及時(shí)獲取線程的運(yùn)行結(jié)果，本文就通過(guò)一個(gè)相關(guān)實(shí)例向大家介紹Java利用future及時(shí)獲取線程運(yùn)行結(jié)果的方法，需要的朋友可以參考。
2017-10-10
JavaCV簡(jiǎn)介與環(huán)境搭建詳細(xì)步驟
JavaCV是一個(gè)開(kāi)源的Java接口,它為幾個(gè)著名的計(jì)算機(jī)視覺(jué)庫(kù)(如OpenCV、FFmpeg)提供了Java封裝,這篇文章主要給大家介紹了關(guān)于JavaCV簡(jiǎn)介與環(huán)境搭建的相關(guān)資料,需要的朋友可以參考下
2024-04-04
SpringCloud+Redis實(shí)現(xiàn)Api接口限流防止惡意刷接口
接口限流是為了保護(hù)系統(tǒng)和服務(wù),防止因?yàn)檫^(guò)多的請(qǐng)求而崩潰,本文主要介紹了SpringCloud+Redis實(shí)現(xiàn)Api接口限流防止惡意刷接口,具有一定的參考價(jià)值,感興趣的可以了解一下
2024-03-03
Springboot 1.5.7整合Kafka-client代碼示例
這篇文章主要介紹了Springboot 1.5.7整合Kafka-client代碼示例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-10-10
SpringBoot壓縮json并寫(xiě)入Redis的示例代碼
由于業(yè)務(wù)需要,存入redis中的緩存數(shù)據(jù)過(guò)大,占用了10+G的內(nèi)存,內(nèi)存作為重要資源,需要優(yōu)化一下大對(duì)象緩存,所以我們需要對(duì)json進(jìn)行壓縮,本文給大家介紹了SpringBoot如何壓縮Json并寫(xiě)入redis,需要的朋友可以參考下
2024-08-08
java程序打包成exe與jar的圖文教程
這篇文章主要介紹了java程序打包成exe與jar的圖文教程，有需要的朋友可以參考一下
2014-01-01