一切福田，不離方寸，從心而覓，感無不通。

在CentOS7上安装RabbitMQ

安装过程参考官网：

Installing on RPM-based Linux (RHEL, CentOS, Fedora, openSUSE)

首先需要安装erlang，参考：http://fedoraproject.org/wiki/EPEL/FAQ#howtouse

1
2
rpm -Uvh https://mirrors.tuna.tsinghua.edu.cn/epel/epel-release-latest-7.noarch.rpm
yum install erlang

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

完成后安装RabbitMQ：

先下载rpm：

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

下载完成后安装：

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

完成后启动服务：

1
service rabbitmq-server start

可以查看服务状态：

1
service rabbitmq-server status

这里可以看到log文件的位置，转到文件位置，打开文件：

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

1
2
cd /etc/rabbitmq/
vi rabbitmq.config

编辑内容如下：

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

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

保存配置后重启服务：

1
2
service rabbitmq-server stop
service rabbitmq-server start

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

1
2
3
rm rabbit\@mythsky.log
service rabbitmq-server stop
service rabbitmq-server start

 

开放5672端口：

1
2
firewall-cmd --zone=public --add-port=5672/tcp --permanent
firewall-cmd --reload

在Windows上进行测试：

新建.net core控制台项目，引用RabbitMQ.Client包：

1
Install-Package RabbitMQ.Client

测试代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
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);
            }
        }

也可以使用官网的例子（这里更清晰）：

http://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html

发送端：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
using System;
using System.Text;
using RabbitMQ.Client;
 
namespace rabbitMQ
{
    public class Send
    {
        public static void Main()
        {
            var factory = new ConnectionFactory() { HostName = "192.168.0.169", UserName = "user", Password = "pass" };
            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!" + DateTime.Now;
                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();
        }
    }
}

接收端：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
 
namespace rabbitMQ
{
    class Receive
    {
        public static void Main()
        {
            var factory = new ConnectionFactory() { HostName = "192.168.0.169", UserName = "user", Password = "pass" };
            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",
                    autoAck: true,
                    consumer: consumer);
 
                Console.WriteLine(" Press [enter] to exit.");
                Console.ReadLine();
            }
        }
    }
}

在Windows上发送，在CentOS上接收，效果如图：

 

开启管理UI：

1
2
3
rabbitmq-plugins enable rabbitmq_management
firewall-cmd --zone=public --add-port=15672/tcp --permanent
firewall-cmd --reload

在Windows下打开地址：

1
http://10.255.19.111:15672

用户名和密码都是 guest

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

 

from:https://www.cnblogs.com/uptothesky/p/6094357.html

Copyright © 2024 Longsheng All rights reserved.