Java 项目中使用 TongLink/Q 实现消息队列传输

TongLink/Q 是一款基于 Apache Pulsar 的消息中间件服务，它提供了一种高效的、分布式的消息传递解决方案，常用于 Java 项目的异步通信场景中。在 Java 项目中，你可以通过 TongLink/Q 集成 Pulsar 客户端库来实现消息队列功能：

1. **环境准备**：首先需要在项目中添加 TongLink/Q 或者 Pulsar 官方的客户端依赖。如果你使用 Maven，可以在 `pom.xml` 中添加相应的仓库和依赖。

<dependency>
    <groupId>com.taobao.tonglink</groupId>
    <artifactId>tonglink-pulsar-client</artifactId>
    <version>版本号</version>
</dependency>

2. **创建生产者**：创建一个生产者实例，用于将消息发送到主题 (topic) 上。

PulsarClient client = PulsarClient.builder()
    .serviceUrl("pulsar://localhost:6650") // 连接 Pulsar 服务器地址
    .build();

Producer producer = client.newProducer()
    .topic("my-topic") // 指定主题
    .create();
    
// 发送消息
producer.send(data);

3. **创建消费者**：创建消费者实例，用于从主题接收并处理消息。

Consumer consumer = client.newConsumer().topic("my-topic")
    .subscriptionName("my-subscription") // 设置订阅名称
    .subscribe();

Message msg = consumer.receive(1000); // 等待最多1秒接收消息
if (msg != null) {
    System.out.println(msg.getData());
}

4. **错误处理与关闭连接**：记得在完成后关闭连接和资源释放。

consumer.close();
client.close();