使用Reactor Netty连接到服务器消息队列

<dependency>
    <groupId>io.projectreactor.netty</groupId>
    <artifactId>reactor-netty</artifactId>
    <version>0.9.0.RELEASE</version>
</dependency>

import reactor.netty.tcp.TcpClient;

TcpClient.create()
    .host("rabbitmq.example.com")
    .port(5672)
    .connect()
    .subscribe(connection -> {
        // 连接成功后的处理逻辑
    });

import reactor.core.publisher.Mono;
import reactor.rabbitmq.OutboundMessage;
import reactor.rabbitmq.Sender;

Sender sender = RabbitFlux.createSender();

OutboundMessage message = new OutboundMessage(
    "exchangeName",
    "routingKey",
    "Hello, RabbitMQ!".getBytes()
);

Mono<Void> mono = sender.send(Mono.just(message));
mono.subscribe();

connection.dispose();