疫情结束了,还在因为不会rabbitmq而找不到工作吗?**
小祥一个简单的rabbitmq初战demo,希望给大家带来帮助。
1.首先安装RabbitMq
安装RabbitMQ需要先安装Erlang语言开发包。下载地址 http://www.erlang.org/download.html
配置ERLANG环境变量。ERLANG_HOME C:\Program Files (x86)\erl-23(安装路径)
添加到PATH %ERLANG_HOME%\bin;
安装RabbitMQ 下载地址 http://www.rabbitmq.com/download.html
配置RabbitMQ环境变量。RABBITMQ_SERVER C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-2.8.0(安装路径) 添加到PATH %RABBITMQ_SERVER%\sbin;
2.建立一个maven项目
添加依赖到pom.xml文件
<dependencies>
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.5.3</version>
</dependency>
</dependencies>
3.创建生产者端
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 Producer {
public static void main(String[] args) throws IOException, TimeoutException {
// 创建一个ConnectionFactory 工厂
ConnectionFactory connectionFactory = new ConnectionFactory();
// 主机
connectionFactory.setHost("localhost");
// 端口号
connectionFactory.setPort(5672);
// 用户名
connectionFactory.setUsername("guest");
// 密码
connectionFactory.setPassword("guest");
// 虚拟主机
connectionFactory.setVirtualHost("/");
Connection connection = null;
Channel channel = null;
try {
// 创建连接
connection = connectionFactory.newConnection();
// 创建通道
channel = connection.createChannel();
// 发送10次数据
for (int i = 1; i < 11; i++) {
String msg = "第" + i + "次Hello World!";
channel.basicPublish("", "queue1", null, msg.getBytes());
}
} catch (IOException e) {
e.printStackTrace();
} catch (TimeoutException e) {
e.printStackTrace();
} finally {
// 关闭连接
if (channel != null) {
channel.close();
}
if (connection != null) {
connection.close();
}
}
}
}
4.创建消费者端
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;
public class Consumer {
private final static String QUEUE_NAME = "queue1";
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ConnectionFactory();
// 主机地址
connectionFactory.setHost("127.0.0.1");
// 端口号
connectionFactory.setPort(5672);
// 用户名
connectionFactory.setUsername("guest");
// 密码
connectionFactory.setPassword("guest");
// 虚拟主机
connectionFactory.setVirtualHost("/");
// 2通过连接工厂创建连接
Connection connection = connectionFactory.newConnection();
// 3通过connection 创建一个Channel
Channel channel = connection.createChannel();
// 4 声明一个队列
channel.queueDeclare(QUEUE_NAME, true, false, false, null);
// 5.创建消费者
QueueingConsumer queueingConsumer = new QueueingConsumer(channel);
// 6 设置通道
channel.basicConsume(QUEUE_NAME, true, queueingConsumer);
while (true) {
// 7 获取消息
QueueingConsumer.Delivery delivery = queueingConsumer.nextDelivery();
String msg = new String(delivery.getBody());
System.out.println("消费端获取到的信息: " + msg);
}
}
}
5.运行消费者和生产者
运行结果如下,共获得十条消息,是不是很简单~