springboot使用消息中間件
更新時(shí)間：2019年10月21日 14:17:38 作者：三鮮豆皮
這篇文章主要介紹了springboot使用消息中間件,文中通過示例代碼介紹的非常詳細(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í)有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:
- SpringBoot微信消息接口配置詳解
- Spring boot項(xiàng)目redisTemplate實(shí)現(xiàn)輕量級(jí)消息隊(duì)列的方法
- Spring Boot RabbitMQ 延遲消息實(shí)現(xiàn)完整版示例
- 詳解Spring Boot 定制HTTP消息轉(zhuǎn)換器
- SpringBoot利用redis集成消息隊(duì)列的方法
- spring boot整合spring-kafka實(shí)現(xiàn)發(fā)送接收消息實(shí)例代碼
- SpringBoot webSocket實(shí)現(xiàn)發(fā)送廣播、點(diǎn)對(duì)點(diǎn)消息和Android接收
- Spring Boot實(shí)戰(zhàn)之netty-socketio實(shí)現(xiàn)簡(jiǎn)單聊天室(給指定用戶推送消息)
相關(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ū)別解析,文中通過示例代碼介紹的非常詳細(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)稱MP）是基于MyBatis框架基礎(chǔ)上開發(fā)的增強(qiáng)型工具，旨在簡(jiǎn)化開發(fā)、提高效率。本文將為大家詳細(xì)介紹一下MyBatisPlus是使用，需要的可以參考一下2022-07-07
Java利用future及時(shí)獲取多線程運(yùn)行結(jié)果
在Java編程中，有時(shí)候會(huì)需要及時(shí)獲取線程的運(yùn)行結(jié)果，本文就通過一個(gè)相關(guān)實(shí)例向大家介紹Java利用future及時(shí)獲取線程運(yùn)行結(jié)果的方法，需要的朋友可以參考。2017-10-10
JavaCV簡(jiǎn)介與環(huán)境搭建詳細(xì)步驟
JavaCV是一個(gè)開源的Java接口,它為幾個(gè)著名的計(jì)算機(jī)視覺庫(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)檫^多的請(qǐng)求而崩潰,本文主要介紹了SpringCloud+Redis實(shí)現(xiàn)Api接口限流防止惡意刷接口,具有一定的參考價(jià)值,感興趣的可以了解一下2024-03-03
Springboot 1.5.7整合Kafka-client代碼示例
這篇文章主要介紹了Springboot 1.5.7整合Kafka-client代碼示例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-10-10
由于業(yè)務(wù)需要,存入redis中的緩存數(shù)據(jù)過大,占用了10+G的內(nèi)存,內(nèi)存作為重要資源,需要優(yōu)化一下大對(duì)象緩存,所以我們需要對(duì)json進(jìn)行壓縮,本文給大家介紹了SpringBoot如何壓縮Json并寫入redis,需要的朋友可以參考下2024-08-08
這篇文章主要介紹了java程序打包成exe與jar的圖文教程，有需要的朋友可以參考一下2014-01-01