麻豆一区二区-麻豆一区-麻豆一精品传媒媒短视频下载-麻豆亚洲一区-麻豆亚洲-麻豆性视频

首頁 > 綜合 > 正文

全球視訊！配置Spring Cloud Bus并集成消息代理示例

2023-04-17 14:17:43來源：騰訊云  

我們將創建兩個微服務：一個是 Order Service，另一個是 Product Service。這兩個服務將使用 Spring Cloud Bus 和 RabbitMQ 來進行消息傳遞。

Order Service

首先，讓我們來創建 Order Service。


(資料圖)

@SpringBootApplication@RestController@EnableBinding(Sink.class)public class OrderServiceApplication {    private final Logger logger = LoggerFactory.getLogger(getClass());    @StreamListener(Sink.INPUT)    public void handle(String message) {        logger.info("Received message: {}", message);    }    @GetMapping("/order")    public String placeOrder() {        String message = "Order placed";        logger.info("Sending message: {}", message);        return message;    }    public static void main(String[] args) {        SpringApplication.run(OrderServiceApplication.class, args);    }}

這個應用程序使用 @EnableBinding 注解將 Sink綁定到它的消息代理上。它還使用 @StreamListener 注解來指定消息處理方法。

在 Order Service 中，我們還定義了一個 /order REST 端點。當該端點被調用時，應用程序會向消息代理發送一條消息。該消息將被 Product Service 接收并處理。

Product Service

接下來，讓我們來創建 Product Service。

@SpringBootApplication@RestController@EnableBinding(Source.class)public class ProductServiceApplication {    private final Logger logger = LoggerFactory.getLogger(getClass());    private final MessageChannel output;    public ProductServiceApplication(Source source) {        this.output = source.output();    }    @PostMapping("/product")    public String addProduct(@RequestBody String product) {        String message = "Product added: " + product;        logger.info("Sending message: {}", message);        output.send(MessageBuilder.withPayload(message).build());        return message;    }    public static void main(String[] args) {        SpringApplication.run(ProductServiceApplication.class, args);    }}

這個應用程序使用 @EnableBinding 注解將 Source 綁定到它的消息代理上。它還定義了一個 /product REST 端點，該端點用于添加新產品。

當 /product 端點被調用時，Product Service 會向消息代理發送一條消息，該消息將被 Order Service 接收并處理。

4.3 運行示例

我們已經創建了 Order Service 和 Product Service，接下來讓我們運行它們并查看消息傳遞的結果。

首先，我們需要啟動 RabbitMQ 服務器。然后，我們可以使用以下命令分別啟動 Order Service 和 Product Service：

mvn spring-boot:run -Dspring-boot.run.arguments=--server.port=8081 (Order Service)mvn spring-boot:run -Dspring-boot.run.arguments=--server.port=8082 (Product Service)

當這兩個服務都已經啟動時，我們可以通過訪問 Order Service 的 /order 端點和 Product Service 的 /product 端點來測試它們之間的消息傳遞。

在 Order Service 的控制臺輸出中，我們應該能夠看到類似以下內容的消息：

Received message: Product added: {product name}

這表明 Product Service 成功地向 Order Service 發送了一條消息，并且 Order Service 成功地接收并處理了該消息。

標簽：

相關閱讀

精彩推薦

相關詞

推薦閱讀

主站蜘蛛池模板： 亚洲a图 | 青青成人福利国产在线视频 | 亚洲精品午夜久久aaa级久久久 | 色多多影院 | 亚洲不卡视频在线观看 | 私人影院在线播放 | 国产一区二区三区久久精品小说 | 四虎影院久久 | www四虎影院 | 亚久久伊人精品青青草原2020 | 国产性色视频 | 免费在线观看成年人视频 | 免费黄色片在线观看 | 亚洲国产成人精品不卡青青草原 | 美女狂揉尿口揉到失禁 | 日本高清在线播放一区二区三区 | 国产综合网站 | 国产精品自产拍在线观看2019 | 国产精品久久久天天影视香蕉 | 大香线一本 | 婚色阿花在线全文免费笔 | 国产精品全国探花在线观看 | 久久中文骚妇内射 | 草莓丝瓜芭乐樱桃榴莲色多黄 | 日韩视频一区二区三区 | 成人欧美一区二区三区黑人 | 欧美成人禁片在线观看俄罗斯 | 亚洲六月丁香六月婷婷色伊人 | 精品日韩欧美一区二区三区 | 草大逼| 日韩在线第一区 | 日本精品欧洲www | 大乳女子一级毛片 | 操人网 | 国产9191精品免费观看 | 精品一产品大全 | 5278欧美一区二区三区 | 日韩视频一区 | 99国产牛牛视频在线网站 | 爱色综合v | 国产在线观看精品香蕉v区 国产在线观看a |