博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
在CentOS7上安装RabbitMQ
阅读量:5377 次
发布时间:2019-06-15

本文共 5270 字,大约阅读时间需要 17 分钟。

安装过程参考官网:

首先需要安装erlang,参考:

rpm -Uvh https://mirrors.ustc.edu.cn/epel/7/x86_64/Packages/e/epel-release-7-11.noarch.rpmyum install erlang

安装过程中会有提示,一路输入“y”即可。

完成后安装RabbitMQ:

先下载rpm:

wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm

下载完成后安装:

yum install rabbitmq-server-3.6.6-1.el7.noarch.rpm

完成后启动服务:

service rabbitmq-server start

可以查看服务状态:

service rabbitmq-server status

这里可以看到log文件的位置,转到文件位置,打开文件:

这里显示的是没有找到配置文件,我们可以自己创建这个文件

cd /etc/rabbitmq/vi rabbitmq.config

编辑内容如下:

[{rabbit, [{loopback_users, []}]}].

这里的意思是开放使用,rabbitmq默认创建的用户guest,密码也是guest,这个用户默认只能是本机访问,localhost或者127.0.0.1,从外部访问需要添加上面的配置。

保存配置后重启服务:

service rabbitmq-server stopservice rabbitmq-server start

此时就可以从外部访问了,但此时再看log文件,发现内容还是原来的,还是显示没有找到配置文件,可以手动删除这个文件再重启服务,不过这不影响使用

rm rabbit\@mythsky.log service rabbitmq-server stopservice rabbitmq-server start systemctl enable rabbitmq-server.service //设置成服务,开机启动

 

开放5672端口:

firewall-cmd --zone=public --add-port=5672/tcp --permanentfirewall-cmd --reload

在Windows上进行测试:

新建.net core控制台项目,引用RabbitMQ.Client包:

Install-Package RabbitMQ.Client

测试代码:

public static void Main(string[] args)        {            ConnectionFactory factory = new ConnectionFactory();            factory.UserName = "guest";            factory.Password = "guest";            factory.VirtualHost = "/";            factory.HostName = "localhost";            //factory.HostName = "10.255.19.111";            try            {                IConnection conn = factory.CreateConnection();                IModel model = conn.CreateModel();                string exchangeName = "test";                string queueName = "testq";                string routingKey = "first";                model.ExchangeDeclare(exchangeName, ExchangeType.Direct);                model.QueueDeclare(queueName, false, false, false, null);                model.QueueBind(queueName, exchangeName, routingKey, null);                byte[] messageBodyBytes = System.Text.Encoding.UTF8.GetBytes("Hello, world!");                model.BasicPublish(exchangeName, routingKey, null, messageBodyBytes);                Console.WriteLine("message sended.");                bool noAck = false;                BasicGetResult result = model.BasicGet(queueName, noAck);                if (result == null)                {                    Console.Write("no message.");                }                else                {                    IBasicProperties props = result.BasicProperties;                    byte[] body = result.Body;                    model.BasicAck(result.DeliveryTag, false);                    string message = System.Text.Encoding.UTF8.GetString(body);                    Console.Write(message);                }            }            catch (Exception ex)            {                Console.Write(ex.Message);            }        }

 也可以使用官网的例子(这里更清晰):

发送端:

using System;using RabbitMQ.Client;using System.Text;class Send{    public static void Main()    {        var factory = new ConnectionFactory() { HostName = "localhost" };        using(var connection = factory.CreateConnection())        using(var channel = connection.CreateModel())        {            channel.QueueDeclare(queue: "hello",                                 durable: false,                                 exclusive: false,                                 autoDelete: false,                                 arguments: null);            string message = "Hello World!";            var body = Encoding.UTF8.GetBytes(message);            channel.BasicPublish(exchange: "",                                 routingKey: "hello",                                 basicProperties: null,                                 body: body);            Console.WriteLine(" [x] Sent {0}", message);        }        Console.WriteLine(" Press [enter] to exit.");        Console.ReadLine();    }}

接收端:

using RabbitMQ.Client;using RabbitMQ.Client.Events;using System;using System.Text;class Receive{    public static void Main()    {        var factory = new ConnectionFactory() { HostName = "localhost" };        using(var connection = factory.CreateConnection())        using(var channel = connection.CreateModel())        {            channel.QueueDeclare(queue: "hello",                                 durable: false,                                 exclusive: false,                                 autoDelete: false,                                 arguments: null);            var consumer = new EventingBasicConsumer(channel);            consumer.Received += (model, ea) =>            {                var body = ea.Body;                var message = Encoding.UTF8.GetString(body);                Console.WriteLine(" [x] Received {0}", message);            };            channel.BasicConsume(queue: "hello",                                 noAck: true,                                 consumer: consumer);            Console.WriteLine(" Press [enter] to exit.");            Console.ReadLine();        }    }}

在Windows上发送,在CentOS上接收,效果如图:

 

开启管理UI:

rabbitmq-plugins enable rabbitmq_managementfirewall-cmd --zone=public --add-port=15672/tcp --permanentfirewall-cmd --reload

在Windows下打开地址:

http://10.255.19.111:15672

用户名和密码都是 guest

这样就可以方便管理RabbitMQ了。

转载于:https://www.cnblogs.com/twinhead/p/8326000.html

你可能感兴趣的文章
团队-科学计算器-项目总结
查看>>
将DataTable中的数据绑定到TreeView中
查看>>
centos 7 问题集锦
查看>>
mysql小知识
查看>>
phpexcel
查看>>
python中最简单的多进程程序
查看>>
python---冒泡和短冒泡排序
查看>>
python---单向循环链表实现
查看>>
PYTHON线程知识再研习F---队列同步Queue
查看>>
Winform WebBrowser加上进度条
查看>>
树莓派的configure配置文件
查看>>
[转]RPA流程自动化-Blueprism认证考试介绍
查看>>
网络教育 全国统一考试 2012年考试工作计划
查看>>
[转]浅谈Android重力感应
查看>>
数据库设计不推荐使用Bool类型
查看>>
POJ 3281 Dining 【最大流】【神建模】
查看>>
查看当前运行的SQL语句
查看>>
js一些常用方法总结
查看>>
PHP二次开发常用的工具|只能在服务器上调试用什么工具开发
查看>>
Windows Azure Virtual Network (10) 使用Azure Access Control List(ACL)设置客户端访问权限
查看>>