在Spring集成中使用RPC的RabbitMQ示例

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=5672
spring.rabbitmq.username=your-username
spring.rabbitmq.password=your-password

@Component
public class RpcClient {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public String sendRpcRequest(String message) {
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        MessageProperties messageProperties = new MessageProperties();
        messageProperties.setReplyTo("rpc.reply.queue");
        Message requestMessage = new Message(message.getBytes(), messageProperties);
        Message responseMessage = rabbitTemplate.sendAndReceive("rpc.request.exchange", "rpc.request.routingKey", requestMessage, correlationData);
        return new String(responseMessage.getBody());
    }
}

@Component
public class RpcServer {

    @RabbitListener(queues = "rpc.request.queue")
    public String handleRpcRequest(String message) {
        // 处理RPC请求并返回响应
        return "Hello, " + message;
    }
}