springboot使用消息中間件

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

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

前言

使用SpringBoot集成rabbitmq實現(xiàn)一個發(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.測試

啟動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測試
  sender.send();
 }
}

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

您可能感興趣的文章:

相關(guān)文章

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