RabbitMQ簡單使用

參考部落格

rabbitmq是乙個在amqp協議標準基礎上完整的，可服用的企業訊息系統。它遵循mozilla public license開源協議，採用 erlang 實現的工業級的訊息佇列(mq)伺服器，rabbit mq 是建立在erlang otp平台上。

windows下使用cmd（以管理員身份執行）進入安裝目錄下，本人使用的安裝路徑，d:\program files\rabbitmq server\rabbitmq_server-3.7.15\sbin

訪問web控制台，http://伺服器ip:15672，預設使用者名稱密碼都是guest

參考：部落格

直接使用nuget安裝rabbitmq.client

using system;

using system.text;
using rabbitmq.client;
namespace rabbitmq_send
; // 建立連線
var connection = factory.createconnection();
// 建立通道
var channel = connection.createmodel();
string queuename = "hellorabbitmq";
// 宣告乙個佇列
channel.queuedeclare(
queue: queuename,// 訊息佇列名稱
durable: false,// 是否快取
exclusive: false,
autodelete: false,
arguments: null
);console.writeline("\n--->rabbitmq連線成功，請輸入訊息，輸入exit退出");
string input = string.empty;
dowhile (input.trim().tolower() != "exit");
channel.close();
connection.close();}}
}

using system;

using system.text;
using system.threading;
using rabbitmq.client;
using rabbitmq.client.events;
namespace rabbitmq_receive
; // 建立連線
var connection = factory.createconnection();
// 建立通道
var channel = connection.createmodel();
string queuename = "hellorabbitmq";
// 宣告佇列
channel.queuedeclare(
queue: queuename,
durable: false,
exclusive: false,
autodelete: false,
arguments: null
);var consumer = new eventingbasicconsumer(channel);
consumer.received += (ch, ea) =>
] 延遲s傳送回執", ea.deliverytag, random+""));
thread.sleep(random);
console.writeline(string.format("已傳送回執", ea.deliverytag));
//確認該訊息已被消費
channel.basicack(ea.deliverytag, false);
};// 啟動消費者
channel.basicconsume(queue: queuename, autoack: false, consumer: consumer);
console.readkey();}}
}

注：

rabbitmq簡單使用

安裝rabbitmq,進入sbin執行rabbitmq service start 傳送者 package com.zhy.rabbit.01 import com.rabbitmq.client.channel import com.rabbitmq.client.connection impor...

rabbitMQ的簡單使用

交換機模式 交換機模式2 fanout模式 交換機模式3 headers模式，總結 生產者 製造訊息 消費者 獲取訊息，處理訊息 路由機制 中轉訊息 四種模式 後三種是交換機模式 direct 不需要交換機，直接傳送到指定佇列，一對一 topic 需要key fanout 廣播模式，不需要key h...

rabbitMq安裝和簡單使用

首先要在 etc yum.repos.d 建立乙個檔案檔案的結尾必須以.repo結尾。eg rabbitmq.repo centos7中新增下面的內容 bintray rabbitmq server name bintray rabbitmq rpm baseurl gpgcheck 0 repo ...