建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
在CentOS7上安裝RabbitMQ詳解
Installing on RPM-based Linux (RHEL, CentOS, Fedora, openSUSE)
rpm -Uvh http://download.Fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-8.noarch.rpm yum install erlang
安裝過程中會有提示，一路輸入“y”即可。
目前創(chuàng)新互聯(lián)已為千余家的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)站空間、網(wǎng)站托管、企業(yè)網(wǎng)站設(shè)計(jì)、鄂托克前網(wǎng)站維護(hù)等服務(wù)，公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。
完成后安裝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
完成后啟動服務(wù)：
service rabbitmq-server start
可以查看服務(wù)狀態(tài)：
service rabbitmq-server status
這里可以看到log文件的位置，轉(zhuǎn)到文件位置，打開文件：
這里顯示的是沒有找到配置文件，我們可以自己創(chuàng)建這個(gè)文件
cd /etc/rabbitmq/ vi rabbitmq.config
編輯內(nèi)容如下：
[{rabbit, [{loopback_users, []}]}].
這里的意思是開放使用，rabbitmq默認(rèn)創(chuàng)建的用戶guest，密碼也是guest，這個(gè)用戶默認(rèn)只能是本機(jī)訪問，localhost或者127.0.0.1，從外部訪問需要添加上面的配置。
保存配置后重啟服務(wù)：
service rabbitmq-server stop service rabbitmq-server start
此時(shí)就可以從外部訪問了，但此時(shí)再看log文件，發(fā)現(xiàn)內(nèi)容還是原來的，還是顯示沒有找到配置文件，可以手動刪除這個(gè)文件再重啟服務(wù)，不過這不影響使用
rm rabbit\@mythsky.log service rabbitmq-server stop service rabbitmq-server start
開放5672端口：
firewall-cmd --zone=public --add-port=5672/tcp --permanent firewall-cmd --reload
在Windows上進(jìn)行測試：
新建.net core控制臺項(xiàng)目，引用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);
}
}
也可以使用官網(wǎng)的例子（這里更清晰）：
http://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html
發(fā)送端：
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上發(fā)送，在CentOS上接收，效果如圖：
開啟管理UI：
rabbitmq-plugins enable rabbitmq_management firewall-cmd --zone=public --add-port=15672/tcp --permanent firewall-cmd --reload
在Windows下打開地址：
http://10.255.19.111:15672
用戶名和密碼都是 guest
這樣就可以方便管理RabbitMQ了。
當(dāng)前題目：在CentOS7上安裝RabbitMQ詳解
文章分享：http://m.5511xx.com/article/cocpdec.html
