java实现Rabbitmq发送两个数字
时间: 2024-05-04 13:21:16 浏览: 89
java程序利用mq发送消息
以下是使用 Java 实现 RabbitMQ 发送两个数字的示例代码:
```java
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class RabbitMQSender {
private static final String QUEUE_NAME = "numbers_queue";
public static void main(String[] args) throws IOException, TimeoutException {
// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setUsername("guest");
factory.setPassword("guest");
// 创建连接
Connection connection = factory.newConnection();
// 创建通道
Channel channel = connection.createChannel();
// 声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// 发送消息
int num1 = 10;
int num2 = 20;
String message = num1 + "," + num2;
channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
System.out.println(" [x] Sent '" + message + "'");
// 关闭通道和连接
channel.close();
connection.close();
}
}
```
在上面的示例中,我们创建了一个名为 "numbers_queue" 的队列,并向队列发送了两个数字 10 和 20。我们把这两个数字连接成一个字符串 "10,20",然后将其转换为字节数组并发送到队列中。
注意,在实际应用中,我们需要根据具体需求为队列设置更多的参数,例如持久化、自动删除等。同时,我们还需要为队列设置消费者,以便从队列中获取数据并进行处理。
阅读全文