欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Springboot集成RabbitMQ并驗證五種消息模型

 更新時間:2024年03月08日 09:18:52   作者:道法自然 實事求是  
RabbitMQ 提供了5種常用消息模型,本文主要介紹了Springboot集成RabbitMQ并驗證五種消息模型,具有一定的參考價值,感興趣的可以了解一下

一、添加依賴

        <!--AMQP依賴,包含RabbitMQ-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

        <!-- 引入knife4j-spring-ui包 /doc.html-->
        <dependency>
            <groupId>com.github.xiaoymin</groupId>
            <artifactId>knife4j-spring-boot-starter</artifactId>
            <version>3.0.3</version>
        </dependency>

二、配置文件中添加RabbitMQ訪問配置

spring.rabbitmq.host=192.168.0.104
spring.rabbitmq.port=5672
spring.rabbitmq.virtual-host=/
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin123

三、消息生產(chǎn)者代碼

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = "生產(chǎn)者服務(wù)")
@RestController
public class ProducerController {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @ApiOperation(value = "基本消息模型")
    @PostMapping("/testHello")
    public String testHello() {
        rabbitTemplate.convertAndSend("hello","hello world");
        return "ok";
    }

    @ApiOperation(value = "work消息模型")
    @PostMapping("/testWork")
    public String testWork() {
        for (int i = 0; i < 10; i++) {
            rabbitTemplate.convertAndSend("work","hello work!");
        }
        return "ok";
    }

    @ApiOperation(value = "訂閱模型-Fanout 廣播模式")
    @PostMapping("/testFanout")
    public String testFanout() {
        rabbitTemplate.convertAndSend("logs","","這是日志廣播");
        return "ok";
    }

    @ApiOperation(value = "訂閱模型-Direct")
    @PostMapping("/testDirect")
    public String testDirect() {
        rabbitTemplate.convertAndSend("directs","error","error 的日志信息");
        return "ok";
    }

    @ApiOperation(value = "訂閱模型-Topic")
    @PostMapping("/testTopic")
    public String testTopic() {
        rabbitTemplate.convertAndSend("topics","user.save.findAll","user.save.findAll 的消息");
        return "ok";
    }
}

四、消息消費者代碼

import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;


@Component
public class SpringRabbitListener {

     //基本消息模型
     @RabbitListener(queuesToDeclare = @Queue("hello"))
     public void receive(String message) {
         System.out.println("message = " + message);
     }

     //work消息模型
     @RabbitListener(queuesToDeclare = @Queue("work"))
     public void workReceive1(String message) {
         System.out.println("workReceive1 message = " + message);
     }
     //work消息模型
     @RabbitListener(queuesToDeclare = @Queue("work"))
     public void workReceive2(String message) {
         System.out.println("workReceive2 message = " + message);
     }

    //訂閱模型-Fanout 廣播模式
    @RabbitListener(bindings = @QueueBinding(value = @Queue, exchange = @Exchange(name="logs",type = "fanout")))
    public void fanoutReceive(String message) {
        System.out.println("fanoutReceive message = " + message);
    }

    //訂閱模型-Direct
    @RabbitListener(bindings ={@QueueBinding(value = @Queue(),key={"info","error"},exchange = @Exchange(type = "direct",name="directs"))})
    public void directReceive(String message) {
        System.out.println("directReceive message = " + message);
    }

    //訂閱模型-Topic
    @RabbitListener(bindings = {@QueueBinding( value = @Queue,key = {"user.*"},exchange = @Exchange(type = "topic",name = "topics"))})
    public void topicReceive1(String message) {
        System.out.println("topicReceive1 message = " + message);
    }
    //訂閱模型-Topic
    @RabbitListener(bindings = {@QueueBinding(value = @Queue,key = {"user.#"},exchange = @Exchange(type = "topic",name = "topics"))})
    public void topicReceive2(String message) {
        System.out.println("topicReceive2 message = " + message);
    }

}

五、驗證

瀏覽器輸入:ip:8080/doc.html 對接口逐個進行測試

參考資料

到此這篇關(guān)于Springboot集成RabbitMQ并驗證五種消息模型的文章就介紹到這了,更多相關(guān)Springboot RabbitMQ驗證消息模型內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家! 

相關(guān)文章

  • java swing實現(xiàn)QQ賬號密碼輸入框

    java swing實現(xiàn)QQ賬號密碼輸入框

    這篇文章主要為大家詳細(xì)介紹了Java swing實現(xiàn)QQ賬號密碼輸入框,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-06-06
  • 最新springboot解決跨域的幾種方式小結(jié)

    最新springboot解決跨域的幾種方式小結(jié)

    跨域指的是瀏覽器不能執(zhí)?其他?站的腳本。它是由瀏覽器的同源策略造成的,是瀏覽器對javascript施加的安全限制,這篇文章主要介紹了springboot解決跨域的幾種方式,需要的朋友可以參考下
    2022-05-05
  • Java中equals和hashcode用法

    Java中equals和hashcode用法

    `equals`和`hashCode`方法在Java中密切相關(guān),必須保持一致性,如果兩個對象通過`equals`方法相等,它們的`hashCode`也必須相同,這對于基于哈希的數(shù)據(jù)結(jié)構(gòu)至關(guān)重要,因為這些結(jié)構(gòu)依賴哈希值進行快速查找和存儲,為了減少哈希沖突
    2025-01-01
  • GraalVM和Spring Native嘗鮮一步步讓Springboot啟動飛起來66ms完成啟動

    GraalVM和Spring Native嘗鮮一步步讓Springboot啟動飛起來66ms完成啟動

    GraalVM是高性能的JDK,支持Java/Python/JavaScript等語言,它可以讓Java變成二進制文件來執(zhí)行,讓程序在任何地方運行更快,這篇文章主要介紹了GraalVM和Spring Native嘗鮮一步步讓Springboot啟動飛起來66ms完成啟動,需要的朋友可以參考下
    2023-02-02
  • java實現(xiàn)貪吃蛇游戲代碼(附完整源碼)

    java實現(xiàn)貪吃蛇游戲代碼(附完整源碼)

    這篇文章主要介紹了java實現(xiàn)貪吃蛇游戲代碼(附完整源碼),本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-01-01
  • Spring?Boot虛擬線程Webflux在JWT驗證和MySQL查詢性能比較

    Spring?Boot虛擬線程Webflux在JWT驗證和MySQL查詢性能比較

    這篇文章主要為大家介紹了Spring Boot虛擬線程與Webflux在JWT驗證和MySQL查詢上的性能比較,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-09-09
  • 用Java編程輸出萬年歷的功能實現(xiàn)

    用Java編程輸出萬年歷的功能實現(xiàn)

    這篇文章主要介紹了用Java編程輸出萬年歷的功能實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-05-05
  • SpringBoot實現(xiàn)Tomcat集群的會話管理功能

    SpringBoot實現(xiàn)Tomcat集群的會話管理功能

    在使用 Tomcat 集群時,由于每個 Tomcat 實例的 Session 存儲是獨立的,導(dǎo)致無法實現(xiàn) Session 的共享,這可能影響到用戶跨節(jié)點的訪問,為了實現(xiàn)跨 Tomcat 實例共享 Session,可以使用 Spring Session 配合 Redis 進行集中式會話管理,需要的朋友可以參考下
    2024-12-12
  • java 中繼承和多態(tài)詳細(xì)介紹

    java 中繼承和多態(tài)詳細(xì)介紹

    這篇文章主要介紹了java 中繼承和多態(tài)詳細(xì)介紹的相關(guān)資料,需要的朋友可以參考下
    2017-05-05
  • 解決idea啟動報錯javax.imageio.IIOException的問題

    解決idea啟動報錯javax.imageio.IIOException的問題

    這篇文章主要介紹了idea啟動報錯javax.imageio.IIOException,解決打不開idea問題,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-09-09

最新評論