网站开发程序员 工资,国内知名摄影网站,seo搜索优化软件,凡客达人的运作模式文章目录 RabbitMQ 安装使用安装下载 Erlang下载 RabbitMQ 的服务安装好后看是否有 RabbitMQ 的服务开启管理 UIRabbitMQ 端口使用一览图 使用输出最简单的 Hello World#xff01;生产者定义消费者消费消息小拓展 RabbitMQ 安装使用
安装
下载 Erlang
RabbitMQ 是用这个语… 文章目录 RabbitMQ 安装使用安装下载 Erlang下载 RabbitMQ 的服务安装好后看是否有 RabbitMQ 的服务开启管理 UIRabbitMQ 端口使用一览图 使用输出最简单的 Hello World生产者定义消费者消费消息小拓展 RabbitMQ 安装使用
安装
下载 Erlang
RabbitMQ 是用这个语言写的这个语言性能好下载就好了。
下载地址
如果是 Windows 直接点击 Installer 下载傻瓜式下载。 下载的时候一般不放到默认路径自己选一个自己特定的安装路径。
下载 RabbitMQ 的服务
下载地址
也是直接点击看下图 安装好后看是否有 RabbitMQ 的服务
如果有这样的服务那就是成功啦。
ctrl R 输入 services.msc
查看服务列表
找到 RabbitMQ 服务如果在运行那么就是安装成功了。 开启管理 UI
在目录打开 sbin 目录
并且在此目录下打开命令行运行 rabbitmq-plugins enable rabbitmq_management 如果没有什么报错的话就说明管理 UI 的插件已经成功配置。
这时候你只需要打开 localhost:15672/ 即可进入管理页面如下 一开始进入如果需要密码的话那么用户明和密码都是 guest
如果你在服务端需要远程管理这个账号是登录不了的需要你自己再去创建一个账号。
RabbitMQ 端口使用一览图
比如 15672 是管理 UI 的端口
RabbitMQ 服务就是运行在端口 5672 使用
这里使用的是 Java 版本 消息队列中的有几个重要的 专有名词一个是生产者producer》 生产消息一个是消费者consumer》 消费消息一个是 broker 对消息进行转发的中间人。还有一个就是 router 路由如何进行转发。 输出最简单的 Hello World
输出 Hello World 就是这样的一个简单的模型。 有一个生产者创造一条消息转发到 Broker 这个是由 RabbitMQ 自动完成一个消费者消费这条消息。
生产者定义
代码中有详细的注释。
package com.xwhking.testcode.TestRabbitMQ;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.nio.charset.StandardCharsets;public class Send {private final static String QUEUE_NAME hello;public static void main(String[] argv) throws Exception {ConnectionFactory factory new ConnectionFactory(); // 创建一个RabbitMQ 的连接工厂factory.setHost(localhost); // 设置RabbitMQ 的主机地址try (Connection connection factory.newConnection(); // 创建一个连接Channel channel connection.createChannel()) { // 创一个管道用于通信传输消息。channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 生命一个队列 第一个参数是队列的名字第二个参数是是否持久化第三个参数是是否独占队列第四个参数是是否自动删除第五个参数是队列的属性。String message Hello World!;channel.basicPublish(, QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8)); // 发布消息第一个参数是交换机名第二个参数是队列名第三个参数是消息的属性第四个参数是消息的内容。传输过程都是以二进制进行传输。System.out.println( [x] Sent message );}}
}运行以后就可以在管理界面看到了。 消费者消费消息
package com.xwhking.testcode.TestRabbitMQ;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
import java.nio.charset.StandardCharsets;public class Recv {private final static String QUEUE_NAME hello; // 队列名字public static void main(String[] argv) throws Exception {ConnectionFactory factory new ConnectionFactory(); // 创建工厂factory.setHost(localhost); // 设置主机Connection connection factory.newConnection(); // 获取一个连接Channel channel connection.createChannel(); // 获取通道channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 声明一个队列参数队列名是否持久化是否独占是否自动删除参数System.out.println( [*] Waiting for messages. To exit press CTRLC);DeliverCallback deliverCallback (consumerTag, delivery) - {String message new String(delivery.getBody(), StandardCharsets.UTF_8);System.out.println( [x] Received message );};// 消费者收到消息的回调函数参数消费者标签消息回调函数内就是处理消息的代码channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag - { }); // 消费者参数队列名是否自动应答回调函数消费者标签}
}消费后管理页面 拥有的一条消息就被消费啦。
小拓展
消费者不是启动以后就是一个阻塞线程吗如果没有消息的来到那么线程会一直阻塞那么我是否能够改一下生产者能够随时输入消息让消费者收到呢。
嗯嗯嗯
说干就干
修改生产者
package com.xwhking.testcode.TestRabbitMQ;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.nio.charset.StandardCharsets;
import java.util.Scanner;public class Send {private final static String QUEUE_NAME hello;public static void main(String[] argv) throws Exception {ConnectionFactory factory new ConnectionFactory(); // 创建一个RabbitMQ 的连接工厂factory.setHost(localhost); // 设置RabbitMQ 的主机地址try (Connection connection factory.newConnection(); // 创建一个连接Channel channel connection.createChannel()) { // 创一个管道用于通信传输消息。channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 生命一个队列 第一个参数是队列的名字第二个参数是是否持久化第三个参数是是否独占队列第四个参数是是否自动删除第五个参数是队列的属性。String message Hello World!;Scanner scanner new Scanner(System.in);while(true){message scanner.nextLine();channel.basicPublish(, QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8)); // 发布消息第一个参数是交换机名第二个参数是队列名第三个参数是消息的属性第四个参数是消息的内容。传输过程都是以二进制进行传输。System.out.println( [x] Sent message );}}}
}大家好我是xwhking一名技术爱好者目前正在全力学习 Java前端也会一点如果你有任何疑问请你评论或者可以加我QQ2837468248说明来意希望能够与你共同进步
