- RabbitMQ 教程
- RabbitMQ - 主页
- RabbitMQ - 概述
- RabbitMQ - 环境设置
- RabbitMQ - 功能
- RabbitMQ - 安装
- 基于队列的示例
- RabbitMQ - 生产者应用程序
- RabbitMQ - 消费者应用程序
- RabbitMQ - 测试应用程序
- 基于主题的示例
- RabbitMQ - 发布者应用程序
- RabbitMQ - 订阅者应用程序
- RabbitMQ - 测试应用程序
- RabbitMQ 有用资源
- RabbitMQ - 快速指南
- RabbitMQ - 有用的资源
- RabbitMQ - 讨论
RabbitMQ - 生产者应用程序
现在让我们创建一个生产者应用程序,它将向 RabbitMQ 队列发送消息。
创建项目
使用 eclipse,选择File → New → Maven Project。勾选“创建一个简单项目(跳过原型选择)”,然后单击“下一步”。
输入详细信息,如下所示 -
groupId - com.tutorialspoint
artifactId - 生产者
版本- 0.0.1-SNAPSHOT
名称- RabbitMQ 生产者
单击完成按钮,将创建一个新项目。
pom.xml
现在更新 pom.xml 的内容以包含 RabbitMQ 的依赖项。
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.tutorialspoint.activemq</groupId> <artifactId>producer</artifactId> <version>0.0.1-SNAPSHOT</version> <name>RabbitMQ Producer</name> <properties> <java.version>11</java.version> </properties> <dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.14.2</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.26</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-simple</artifactId> <version>1.7.26</version> </dependency> </dependencies> </project>
现在创建一个 Producer 类,它将向 RabbitMQ 队列发送消息。
package com.tutorialspoint.rabbitmq; import java.io.IOException; import java.util.Scanner; import java.util.concurrent.TimeoutException; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class Producer { private static String QUEUE = "MyFirstQueue"; public static void main(String[] args) throws IOException, TimeoutException { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclare(QUEUE, false, false, false, null); Scanner input = new Scanner(System.in); String message; do { System.out.println("Enter message: "); message = input.nextLine(); channel.basicPublish("", QUEUE, null, message.getBytes()); } while (!message.equalsIgnoreCase("Quit")); } } }
Producer 类创建连接、创建通道、连接到队列。如果用户输入 quit,则应用程序终止,否则它将使用 basicPublish 方法将消息发送到队列。
我们将在RabbitMQ - 测试应用程序一章中运行此应用程序。