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

SpringCloud中的Stream服務(wù)間消息傳遞詳解

 更新時間：2024年01月31日 09:52:11   作者：卷不動躺不平的粥  
這篇文章主要介紹了SpringCloud中的Stream服務(wù)間消息傳遞詳解,Stream 就是在消息隊列的基礎(chǔ)上,對其進行封裝,可以是我們更方便的去使用,Stream應(yīng)用由第三方的中間件組成,應(yīng)用間的通信通過輸入通道和輸出通道完成,需要的朋友可以參考下

一、Stream 的介紹

Stream 就是在消息隊列的基礎(chǔ)上，對其進行封裝，可以是我們更方便的去使用。

Spring Cloud Stream應(yīng)用由第三方的中間件組成。應(yīng)用間的通信通過輸入通道（input channel）和輸出通道（output channel）完成。這些通道是有Spring Cloud Stream 注入的。而通道與外部的代理（可以理解為上文所說的數(shù)據(jù)中心）的連接又是通過Binder實現(xiàn)的。

二、Stream 的快速入門

2.1 編輯消費者

2.1.1 導(dǎo)入相關(guān)依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

2.1.2 編寫配置文件

spring:
  rabbitmq:
    host: 192.168.31.138
    port: 5672
    username: test
    password: test
    virtual-host: /test

2.1.3 聲明 channel（通道）

通過 @Input() 注解來指定所要聲明的通道。

public interface StreamClient {
    @Input("myMessage")
    SubscribableChannel input();
}

被 @Input 和@Output 注解的方法。其中 @Input 注解的方法返回的是 SubscribableChannel ，@Output 注解的方法返回的是 MessageChannel 。

聲明通道（channel）的方法就是使用 @Input 和 @Output 注解方法。你想要多少通道就注解多少方法。

默認情況下，通道的名稱就是注解的方法的名稱，如果需要自己指定，只需要給這兩個注解傳遞 String 類型的參數(shù)即可。

使用@Input或者@Output注解聲明了通道（channel）的接口。Spring Cloud Stream會自動實現(xiàn)這些接口。

2.1.4 創(chuàng)建和綁定 channel（通道）

使用 @EnableBinding 就能創(chuàng)建和綁定通道（channel）。

@SpringBootApplication
@EnableEurekaClient
@EnableBinding(StreamClient.class)
public class SearchApplication {
    public static void main(String[] args) {
        SpringApplication.run(SearchApplication.class,args);
    }
}

@EnableBinding 注解接收的參數(shù)就是使用 @Input 或者 @Output 注解聲明了通道（channel）的接口。

2.1.5 消費消息

@StreamListener 接收的參數(shù)是要處理的通道（channel）的名，所注解的方法就是處理從通道獲取到的數(shù)據(jù)的方法。方法的參數(shù)就是獲取到的數(shù)據(jù)。

@Component
public class StreamReceiver {
    @StreamListener("myMessage")
    public void msg(Object msg){
        System.out.println("接收到消息："+msg);
    }
}

2.2 編輯生產(chǎn)者

2.2.1 導(dǎo)入相關(guān)依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

2.2.2 編寫配置文件

spring:
  rabbitmq:
    host: 192.168.31.138
    port: 5672
    username: test
    password: test
    virtual-host: /test

2.2.3 聲明 channel（通道）

public interface StreamClient {
    @Output("myMessage")
    MessageChannel output();
}

2.2.4 創(chuàng)建和綁定

@SpringBootApplication
.......
@EnableBinding(StreamClient.class)
public class CustomerApplication {
    public static void main(String[] args) {
        SpringApplication.run(CustomerApplication.class,args);
    }
    
	........
        
}

2.2.5 生產(chǎn)消息

@RestController
public class MessageController {

    @Autowired
    private StreamClient streamClient;

    @GetMapping("/send")
    public String send(){
        streamClient.output().send(MessageBuilder.withPayload("Hello stream!!!!!").build());
        return "消息發(fā)送成功！";
    }
}

2.3 測試

三、Stream 重復(fù)消費消息

避免一個消息被多個消費者消費，只需要將多個消費者指定為一個消費者組即可。

**消費組：**直觀的理解就是一群消費者一起處理消息（每個發(fā)送到消費組的數(shù)據(jù)，僅由消費組中的一個消費者處理）。

spring:
  cloud:
    stream:
      bindings:
        myMessage: #指定channel
          group: customer #指定消費者組

四、Stream 消費者的手動 ACK

4.1 編寫配置文件

spring:
  cloud:
    stream:
      rabbit:
        bindings:
          myMessage: #指定 channel name
            consumer: 
              acknowledgeMode: MANUAL # 指定規(guī)則默認 AUTO

4.2 修改消費消息的方法

消息是帶有 Header 的，類似 Http 的 headler，我們可以通過 @Header 來獲取指定的 Header。

@Component
public class StreamReceiver {
    @StreamListener("myMessage")
    public void msg(Object msg,
                    @Header(name = AmqpHeaders.CHANNEL) Channel channel,
                    @Header(name = AmqpHeaders.DELIVERY_TAG) Long deliveryTag) throws IOException {
        System.out.println("接收到消息："+msg);
        channel.basicAck(deliveryTag,false);
    }
}

到此這篇關(guān)于SpringCloud中的Stream服務(wù)間消息傳遞詳解的文章就介紹到這了,更多相關(guān)SpringCloud的Stream內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

相關(guān)文章

  • SpringBoot實現(xiàn)過濾器攔截器的耗時對比

    SpringBoot實現(xiàn)過濾器攔截器的耗時對比

    這篇文章主要為大家詳細介紹了SpringBoot實現(xiàn)過濾器攔截器的輸出接口耗時對比，文中的示例代碼講解詳細，感興趣的小伙伴可以了解一下
    2022-06-06
  • java實現(xiàn)航空用戶管理系統(tǒng)

    java實現(xiàn)航空用戶管理系統(tǒng)

    這篇文章主要為大家詳細介紹了java實現(xiàn)航空用戶管理系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2021-07-07
  • 詳解Java中Thread 和Runnable區(qū)別

    詳解Java中Thread 和Runnable區(qū)別

    這篇文章主要介紹了Java中Thread 和Runnable的區(qū)別，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-03-03
  • Java的ConcurrentLinkedQueue源碼分析

    Java的ConcurrentLinkedQueue源碼分析

    這篇文章主要介紹了Java的ConcurrentLinkedQueue源碼分析,ConcurrentLinkedQueue 是一個基于鏈接節(jié)點的無界線程安全的隊列,當(dāng)我們添加一個元素的時候,它會添加到隊列的尾部,當(dāng)我們獲取一個元素時,它會返回隊列頭部的元素,需要的朋友可以參考下
    2023-12-12
  • SpringCloud中的服務(wù)接口(api)

    SpringCloud中的服務(wù)接口(api)

    這篇文章主要介紹了SpringCloud中的服務(wù)接口(api),具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-04-04
  • IDEA查看Scala的源碼的教程圖解

    IDEA查看Scala的源碼的教程圖解

    這篇文章主要介紹了IDEA查看Scala的源碼的方法，本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-08-08
  • Spring框架 XML配置事務(wù)控制的步驟操作

    Spring框架 XML配置事務(wù)控制的步驟操作

    這篇文章主要介紹了Spring框架 XML配置事務(wù)控制的步驟操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2021-09-09
  • Java中的while循環(huán)語句詳細講解

    Java中的while循環(huán)語句詳細講解

    這篇文章主要給大家介紹了關(guān)于Java中while循環(huán)語句的相關(guān)資料,while循環(huán)是一種在編程中常見的控制流語句,它允許代碼在特定條件下（通常是一個布爾表達式）重復(fù)執(zhí)行一段代碼,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2024-03-03
  • 更改eclipse的JDK版本詳細步驟

    更改eclipse的JDK版本詳細步驟

    我們用eclipse在做項目的時候會切換jdk版本,本地運行的項目所使用的jdk版本比Linux服務(wù)器高(低),需要調(diào)低(高)JDK版本,這篇文章主要給大家介紹了關(guān)于如何更改eclipse的JDK版本的相關(guān)資料,需要的朋友可以參考下
    2023-11-11
  • SpringMVC中使用Thymeleaf模板引擎實例代碼

    SpringMVC中使用Thymeleaf模板引擎實例代碼

    這篇文章主要介紹了SpringMVC中使用Thymeleaf模板引擎實例代碼，分享了相關(guān)代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下
    2018-02-02

最新評論