两个java程序同时获取rabbitmq的消息

在Java中，如果需要让两个程序同时从RabbitMQ队列中获取消息，通常会通过创建连接和频道的方式进行操作。以下是简要步骤：

1. **添加依赖**：首先，你需要在项目中引入RabbitMQ客户端库，如`com.rabbitmq.client`。

2. **创建连接**：每个程序都需要建立到RabbitMQ服务器的连接。这通常是异步进行的，因为一次只能有一个连接，但可以开启多个线程来处理请求。

ConnectionFactory factory = new ConnectionFactory();
Connection connection = factory.newConnection();

3. **创建频道（Channel）**：连接上创建频道用于发送和接收消息。同样，可以为每个线程创建独立的频道，以便并发访问。

4. **声明交换机（Exchange）和队列**：确定消息路由的交换机以及队列，并设置所需的属性，例如 durable（持久化）和 exclusive（独占）。

5. **绑定（Binding）**：将队列与交换机绑定，指定消息的路由规则。

6. **消费（Consuming）**：在每个频道上创建消费者，使用`BasicConsume`方法开始监听队列。

channel.basicConsume(queueName, true, (consumerTag, delivery) -> {
    // 消息处理逻辑
});

7. **关闭资源**：完成消息处理后，记得关闭通道和连接。

8. **并发控制**：为了防止消息竞争和数据一致性问题，可能需要考虑使用生产者-消费者的模式或者互斥锁。

注意，为了实现两个程序的同时读取，你需要保证消息队列足够大能存储所有的消息，或者调整消息发布策略，比如使用循环队列或多线程处理。