(資料圖片僅供參考)

向指定微服務發送消息

要向指定的微服務發送消息，需要使用 Spring Cloud Bus 提供的 DestinationProvider 接口，該接口可以返回目標微服務的名稱。在消息廣播時，Spring Cloud Bus 會根據目標微服務的名稱將消息發送到指定的微服務中。

例如，我們可以定義一個 DestinationProvider 實現類，用于返回目標微服務的名稱，例如：

@Componentpublic class MyDestinationProvider implements DestinationProvider {    @Override    public String getDestination() {        return "my-service";    }}

在這個例子中，MyDestinationProvider 實現了 DestinationProvider 接口，并實現了 getDestination 方法，返回目標微服務的名稱 my-service。

然后，在需要發送消息的微服務中，可以使用 Spring Cloud Bus 提供的 MessageSender 接口來發送消息，例如：

@RestControllerpublic class MyController {    @Autowired    private MessageSender messageSender;    @PostMapping("/send")    public void sendMessage(@RequestBody String message) {        messageSender.send(new GenericMessage<>(message));    }}

在這個例子中，MyController 中的 sendMessage 方法會使用 MessageSender 接口發送消息，該方法接受一個字符串類型的參數 message，表示要發送的消息。在實際應用中，我們可以將消息封裝成一個對象，然后將對象作為參數傳遞給 sendMessage 方法。