日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

在.NET中集成RabbitMQ實現消息列隊功能,實例解析

來源: 責編: 時間:2024-02-01 12:48:47 192觀看
導讀1、安裝 RabbitMQ首先,你需要安裝 RabbitMQ 服務器。你可以從官方網站下載 RabbitMQ,并按照官方文檔進行安裝和配置。安裝完成后,確保 RabbitMQ 服務器正在運行。2、使用 RabbitMQ 基本功能(1)發布和訂閱消息RabbitMQ 的基

Mqh28資訊網——每日最新資訊28at.com

1、安裝 RabbitMQ

首先,你需要安裝 RabbitMQ 服務器。你可以從官方網站下載 RabbitMQ,并按照官方文檔進行安裝和配置。安裝完成后,確保 RabbitMQ 服務器正在運行。Mqh28資訊網——每日最新資訊28at.com

2、使用 RabbitMQ 基本功能

(1)發布和訂閱消息

RabbitMQ 的基本工作方式是生產者將消息發布到交換機,然后由消費者從隊列中訂閱消息。以下是一個示例:Mqh28資訊網——每日最新資訊28at.com

// 生產者var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){    channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);    var message = "Hello, RabbitMQ!";    var body = Encoding.UTF8.GetBytes(message);    channel.BasicPublish(exchange: "logs", routingKey: "", basicProperties: null, body: body);    Console.WriteLine("Sent: {0}", message);}// 消費者var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){    channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);    var queueName = channel.QueueDeclare().QueueName;    channel.QueueBind(queue: queueName, exchange: "logs", routingKey: "");        var consumer = new EventingBasicConsumer(channel);    consumer.Received += (model, ea) =>    {        var body = ea.Body.ToArray();        var message = Encoding.UTF8.GetString(body);        Console.WriteLine("Received: {0}", message);    };    channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);}

上述代碼中,生產者將消息發布到名為 "logs" 的交換機,而消費者從該交換機創建一個隊列并訂閱消息。Mqh28資訊網——每日最新資訊28at.com

(2)路由消息

RabbitMQ 允許你使用路由鍵將消息路由到特定隊列。以下是一個示例:Mqh28資訊網——每日最新資訊28at.com

// 生產者var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){    channel.ExchangeDeclare(exchange: "direct_logs", type: ExchangeType.Direct);    var severity = "info";    var message = "Informational message.";    var body = Encoding.UTF8.GetBytes(message);    channel.BasicPublish(exchange: "direct_logs", routingKey: severity, basicProperties: null, body: body);    Console.WriteLine("Sent: [{0}] {1}", severity, message);}// 消費者var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){    channel.ExchangeDeclare(exchange: "direct_logs", type: ExchangeType.Direct);    var queueName = channel.QueueDeclare().QueueName;    var severity = "info";    channel.QueueBind(queue: queueName, exchange: "direct_logs", routingKey: severity);    var consumer = new EventingBasicConsumer(channel);    consumer.Received += (model, ea) =>    {        var body = ea.Body.ToArray();        var message = Encoding.UTF8.GetString(body);        Console.WriteLine("Received: [{0}] {1}", severity, message);    };    channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);}

在此示例中,消息被路由到具有特定路由鍵 "info" 的隊列。Mqh28資訊網——每日最新資訊28at.com

(3)主題交換機

RabbitMQ 還支持主題交換機,允許你根據模式匹配消息的路由鍵進行訂閱。以下是一個示例:Mqh28資訊網——每日最新資訊28at.com

// 生產者var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){    channel.ExchangeDeclare(exchange: "topic_logs", type: ExchangeType.Topic);    var routingKey = "kern.critical";    var message = "Critical kernel error.";    var body = Encoding.UTF8.GetBytes(message);    channel.BasicPublish(exchange: "topic_logs", routingKey: routingKey, basicProperties: null, body: body);    Console.WriteLine("Sent: [{0}] {1}", routingKey, message);}// 消費者var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){    channel.ExchangeDeclare(exchange: "topic_logs", type: ExchangeType.Topic);    var queueName = channel.QueueDeclare().QueueName;    var routingKey = "kern.*";    channel.QueueBind(queue: queueName, exchange: "topic_logs", routingKey: routingKey);    var consumer = new EventingBasicConsumer(channel);    consumer.Received += (model, ea) =>    {        var body = ea.Body.ToArray();        var message = Encoding.UTF8.GetString(body);        Console.WriteLine("Received: [{0}] {1}", routingKey, message);    };    channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);}

在此示例中,消息被路由到匹配模式 "kern.*" 的隊列。Mqh28資訊網——每日最新資訊28at.com

3、其他功能

RabbitMQ 還支持消息持久化、RPC(遠程過程調用)、集群和安全等功能。你可以根據項目需求探索這些功能,并使用RabbitMQ的官方文檔和.NET客戶端庫來實現。Mqh28資訊網——每日最新資訊28at.com

上述示例涵蓋了RabbitMQ的一些常見用例,希望可以幫助你入門RabbitMQ并在.NET應用程序中使用它。Mqh28資訊網——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-70422-0.html在.NET中集成RabbitMQ實現消息列隊功能,實例解析

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 面試官:什么是JIT、逃逸分析、鎖消除、棧上分配和標量替換?

下一篇: Rust讀取文件的五種方法,你知道哪種?

標簽:
  • 熱門焦點
  • 影音體驗是真的強 簡單聊聊iQOO Pad

    大公司的好處就是產品線豐富,非常細分化的東西也能給你做出來,例如早先我們看到了新的vivo Pad2,之后我們又在iQOO Neo8 Pro的發布會上看到了iQOO的首款平板產品iQOO Pad。雖
  • 5月iOS設備好評榜:iPhone 14僅排第43?

    來到新的一月,安兔兔的各個榜單又重新匯總了數據,像安卓陣營的榜單都有著比較大的變動,不過iOS由于設備的更新換代并沒有那么快,所以相對來說變化并不大,特別是iOS好評榜,老款設
  • 容量越大越不壞?24萬塊硬盤故障率報告公布 這些產品零故障

    8月5日消息,云存儲服務商Backblaze發布了最新的硬盤故障率報告,年故障率有所上升。Backblaze發布的硬盤季度統計數據,其中包括故障率等重要方面。這些結
  • K6:面向開發人員的現代負載測試工具

    K6 是一個開源負載測試工具,可以輕松編寫、運行和分析性能測試。它建立在 Go 和 JavaScript 之上,它被設計為功能強大、可擴展且易于使用。k6 可用于測試各種應用程序,包括 Web
  • 掘力計劃第 20 期:Flutter 混合開發的混亂之治

    在掘力計劃系列活動第20場,《Flutter 開發實戰詳解》作者,掘金優秀作者,Github GSY 系列目負責人戀貓的小郭分享了Flutter 混合開發的混亂之治。Flutter 基于自研的 Skia 引擎
  • Java NIO內存映射文件:提高文件讀寫效率的優秀實踐!

    Java的NIO庫提供了內存映射文件的支持,它可以將文件映射到內存中,從而可以更快地讀取和寫入文件數據。本文將對Java內存映射文件進行詳細的介紹和演示。內存映射文件概述內存
  • 虛擬鍵盤 API 的妙用

    你是否在遇到過這樣的問題:移動設備上有一個固定元素,當激活虛擬鍵盤時,該元素被隱藏在了鍵盤下方?多年來,這一直是 Web 上的默認行為,在本文中,我們將探討這個問題、為什么會發生
  • 微軟邀請 Microsoft 365 商業用戶,測試視頻編輯器 Clipchamp

    8 月 1 日消息,微軟近日宣布即將面向 Microsoft 365 商業用戶,開放 Clipchamp 應用,邀請用戶通過該應用來編輯視頻。微軟于 2021 年收購 Clipchamp,隨后開始逐步整合到 Microsof
  • 慕巖炮轟抖音,百合網今何在?

    來源:價值研究所 作者:Hernanderz“難道就因為自己的一個產品牛逼了,從客服到總裁,都不愿意正視自己產品和運營上的問題,選擇逃避了嗎?”這一番話,出自百合網聯合創
Top 主站蜘蛛池模板: 青海省| 九龙坡区| 道真| 会昌县| 黄浦区| 铜梁县| 祁连县| 安新县| 泰宁县| 灵丘县| 稷山县| 疏勒县| 阜新| 昌宁县| 武夷山市| 宜兰市| 洪湖市| 刚察县| 锡林浩特市| 九江市| 阳信县| 额敏县| 孙吴县| 成都市| 玛沁县| 塘沽区| 长宁区| 曲周县| 阿合奇县| 玉溪市| 雷山县| 罗平县| 汉川市| 镇康县| 喜德县| 安义县| 马关县| 闸北区| 荔浦县| 庆元县| 河西区|