當(dāng)涉及到消息發(fā)送和接收的場(chǎng)景時(shí)，可以使用Spring Boot和消息中間件RabbitMQ來(lái)實(shí)現(xiàn)。下面是一個(gè)簡(jiǎn)單的示例代碼，展示了如何在Spring Boot應(yīng)用程序中創(chuàng)建消息發(fā)送者和接收者，并發(fā)送和接收一條消息。

首先，你需要進(jìn)行以下準(zhǔn)備工作

1. 確保你已經(jīng)安裝了Java和Maven，并設(shè)置好相應(yīng)的環(huán)境變量。

2. 選擇一個(gè)消息中間件作為你的消息代理，并確保已經(jīng)安裝和配置好該消息中間件。

3. 創(chuàng)建一個(gè)新的Spring Boot項(xiàng)目，并添加相應(yīng)的依賴(lài)項(xiàng)。

現(xiàn)在，讓我們來(lái)編寫(xiě)代碼

1. 創(chuàng)建一個(gè)名為 MessageSender的類(lèi)，用于發(fā)送消息。

import?org.springframework.amqp.core.Queue;
import?org.springframework.amqp.rabbit.core.RabbitTemplate;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.stereotype.Component;

@Component
public?class?MessageSender?{

????@Autowired
????private?RabbitTemplate?rabbitTemplate;

????public?void?sendMessage(String?message)?{
????????rabbitTemplate.convertAndSend("queue_email",?message);
????????System.out.println("Message?sent:?"?+?message);
????}
}

2. 創(chuàng)建一個(gè)名為 MessageReceiver的類(lèi)，用于接收消息。

import?org.springframework.amqp.rabbit.annotation.RabbitListener;
import?org.springframework.stereotype.Component;

@Component
public?class?MessageReceiver?{

????@RabbitListener(queues?=?"queue_email")
????public?void?receiveMessage(String?message)?{
????????System.out.println("Message?received:?"?+?message);
????}
}

3. 創(chuàng)建一個(gè)名為 Application的類(lèi)，作為啟動(dòng)類(lèi)。

import?org.springframework.boot.SpringApplication;
import?org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public?class?Application?{

????public?static?void?main(String[]?args)?{
????????SpringApplication.run(Application.class,?args);
????}
}

4. 創(chuàng)建一個(gè)名為 application.properties的配置文件，并添加以下配置：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

以上代碼示例中使用了RabbitMQ作為消息中間件，你可以根據(jù)自己的需求選擇其他消息中間件，并相應(yīng)地更改配置。

5. 配置指定的隊(duì)列

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?queue()?{
????????return?new?Queue("queue_email");
????}
????
}

現(xiàn)在你可以在應(yīng)用程序的其他地方使用MessageSender類(lèi)發(fā)送消息，例如在某個(gè)控制器中：

import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.web.bind.annotation.GetMapping;
import?org.springframework.web.bind.annotation.RestController;

@RestController
public?class?MessageController?{

????@Autowired
????private?MessageSender?messageSender;

????@GetMapping("/send-message")
????public?String?sendMessage()?{
????????messageSender.sendMessage("Hello,?World!");
????????return?"Message?sent";
????}
}

當(dāng)你運(yùn)行這個(gè)Spring Boot應(yīng)用程序時(shí)，可以通過(guò)訪問(wèn)/send-message端點(diǎn)來(lái)發(fā)送一條消息。這條消息將被發(fā)送到名為queue_email的隊(duì)列中，并由MessageReceiver類(lèi)中的receiveMessage方法接收和處理。

這是一個(gè)簡(jiǎn)單的示例，用于演示如何在Spring Boot應(yīng)用程序中發(fā)送和接收消息?？梢愿鶕?jù)實(shí)際需求進(jìn)行修改和擴(kuò)展，添加更多的功能和業(yè)務(wù)邏輯。