2. 程式人生 > >RabbitMQ學習（三）訂閱/發布

RabbitMQ學習（三）訂閱/發布

阿新 • • 發佈：2017-07-13
cto submit actor nal chan true exec oid lsp

RabbitMQ學習（三）訂閱/發布

1.RabbitMQ模型

技術分享

前面所學都只用到了生產者、隊列、消費者。如上圖所示，其實生產者並不直接將信息傳輸到隊列中，在生產者和隊列中間有一個交換機（Exchange）,我們之前沒有使用到交換機是應為我們沒有配置交換機，使用了默認的交換機。

有幾個可供選擇的交換機類型：直連交換機（direct）, 主題交換機（topic）, （頭交換機）headers和 扇型交換機（fanout）

這裏我們使用扇形交換機做一個簡單的廣播模型：一個生產者和多個消費者接受相同消息；

生產者代碼：

public class Productor {
public static void

main(String[] args) throws IOException, TimeoutException {
//配置rabbitmq服務器地址
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
factory.setUsername("starktan");
factory.setPassword("starktan"
);
factory.setVirtualHost("/");
//建立連接和通道
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
//聲明一個扇形交換機
channel.exchangeDeclare("fanout", BuiltinExchangeType.FANOUT);
System.out.println("
發送信息！");
String message = "WorkQueue Message number " + System.currentTimeMillis();
channel.basicPublish("fanout", "", true, null, message.getBytes());
channel.close();
connection.close();
}
}

消費者代碼：

public class Consumer {

    public static void main(String[] args) throws IOException, InterruptedException, TimeoutException {

        //創建連接和通道

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("localhost");

        final Connection connection = factory.newConnection();

        ExecutorService service = Executors.newFixedThreadPool(10);

        for (int i = 0; i < 4; i++) {

            final int cur = i;

            service.submit(new Runnable() {

                Channel channel = connection.createChannel();

                String queryname = channel.queueDeclare().getQueue();

                public void run() {

                    //創建隊列消費者

                    QueueingConsumer consumer = new QueueingConsumer(channel);

                    try {

                        channel.queueBind(queryname,"fanout","");

                        channel.basicConsume(queryname,consumer);

                        while (true) {

                            QueueingConsumer.Delivery delivery = consumer.nextDelivery();

                            String message = new String(delivery.getBody());

                            System.out.println("線程 " + cur + " 獲取到消息 " + message);

  

                        }

                    } catch (Exception e) {

                        e.printStackTrace();

                    }

                }

            });

        }

        service.shutdown();

    }

}

運行效果：

技術分享

RabbitMQ學習（三）訂閱/發布

相關推薦

RabbitMQ學習（三）訂閱/發布

cto submit actor nal chan true exec oid lsp RabbitMQ學習（三）訂閱/發布 1.RabbitMQ模型 前面所學都只用到了生產者、隊列、消費者。如上圖所示，其實生產者並不直接將信息傳輸到隊列中，在生產者和隊列

RabbitMQ學習第三記：發布/訂閱模式（Publish/Subscribe）

font image 直接 email err spl 回調方法 byte [] 　　工作隊列模式是直接在生產者與消費者裏聲明好一個隊列，這種情況下消息只會對應同類型的消費者。 　　舉個用戶註冊的列子：用戶在註冊完後一般都會發送消息通知用戶註冊成功（失敗）。如果在一個系統中

ROS與Arduino學習（三）訂閱與發布

CP HA hat true subscribe href 串口 chat ria ROS與Arduino學習（二）訂閱與發布 Tutorial Level:HelloWorld Next Tutorial： 本節介紹如何在arduino中發布與訂閱消息。他和ROS通過串口

Spring Cloud Stream教程（三）持續發布 - 訂閱支持

點對點 cst 服務 均值 而不是 兩個 搭建 另一個 進行 應用之間的通信遵循發布訂閱模式，其中通過共享主題廣播數據。這可以在下圖中看到，它顯示了一組交互式的Spring Cloud Stream應用程序的典型部署。 SCSt傳感器圖6. Spring Cloud Str

rabbitmq學習（三）：rabbitmq之扇形交換機、主題交換機

 前言 上篇我們學習了rabbitmq的作用以及直連交換機的程式碼實現，這篇我們繼續看如何用程式碼實現扇形交換機和主題交換機 一、扇形交換機 　　1.生產者 　　 /** * 生產者 */ public class LogProducer { //交換機名稱 pu

RabbitMQ學習（三）：Spring整合RabbitMQ

1、maven依賴 <!-- rabbitMQ依賴 --> <!-- spring相關的其他依賴請參考原始碼，此處不做過多描述 --> <dependency>

rabbitmq學習（三） —— 工作隊列

增加 abi mar outline inter boolean actor conn 消息 工作隊列，又稱任務隊列，主要思想是避免立即執行資源密集型任務，並且必須等待完成。相反地，我們進行任務調度，我們將一個任務封裝成一個消息，並將其發送到隊列。工作進行在後臺運行不斷的從

RabbitMQ入門（三）訂閱模式

  在之前的文章RabbitMQ入門（二）工作佇列中，我們建立了一個工作佇列。工作佇列背後的假設是每一項任務都被準確地傳送至一個worker。在本文中，我們將會做一些不同的事情——我們將會把一個訊息傳送至許多消費者中。這種模式被稱為訂閱模式（publish/subscribe）。   為了解釋這種模式，我們將

Git+Jenkins學習之路（八）之發布maven項目及按版本發布

maven 創建 tar.gz pri .cn class a settings sed family 一、什麽是Maven maven是一個項目管理和綜合工具。Maven提供給開發人員構建一個完整的生命周期框架。 開發團隊可以自動完成該項目的基礎設施建設，

CSS布局學習（三） - position屬性定義及解釋(官網直譯)

mage http docs stand 屏幕 保留 gin 技術 地址 static ①元素的位置是在文檔正常布局流中的位置。 ②設置top right bottom left與z-index無效。 ③在未指定position時，static是默認值 以下例子進行

CSS布局學習（三） - Normal Flow 正常布局流(官網直譯)

add mar pla png 分享圖片 解釋 現象 垂直 邊距 默認情況下，元素是如何布局？ 首先，取得元素的內容，加上內邊距（padding），邊框（border），外邊距（margin）放在一個盒子中 - 這就是我們之前看到的盒子模型 默認情況下，塊級元素的內容寬

觀察者模式（Observer）和發布（Publish/訂閱模式（Subscribe）的區別

enc can 處理 ted cas clas script prot add 源地址：https://blog.csdn.net/qq_39877296/article/details/79103206 觀察者模式（Observer）和發布（Publish/訂閱模式（S

爬蟲庫之BeautifulSoup學習（三）

子節點 rom lac repr 文檔 strong 爬蟲 time contents 遍歷文檔樹： 　　1、查找子節點 　　.contents　　 　　tag的.content屬性可以將tag的子節點以列表的方式輸出。 　　print soup.body.cont

Java學習（三）JSP學習1

rtm 斷開 三大指令 保持 web應用 對比 c語言 let 新建 一、 理解JSP技術 　　JSP全名為Java Server Pages，中文名叫java服務器頁面，其根本是一個簡化的Servlet設計，它 是由Sun Microsystems公司倡導、許多公司參

java學習（三）類

con void pub oid 修改密碼 tro int str 用戶 類 public class Dog{ String breed; int age; String color; void barking(){ } void hungr

Qt Installer Framework的學習（三）

科技 released his 表示 star online 解壓 dem 普通 Qt Installer Framework的學習（三） Qt Installer Framework的樣例中。通常是這種：config目錄一般放了一個config.xml文件，包括的是安裝

PYTHON學習（三）之利用python進行數據分析(1)---準備工作

-- 下載 rip 安裝包 png 要求 eight code 電腦 　　學習一門語言就是不斷實踐，python是目前用於數據分析最流行的語言，我最近買了本書《利用python進行數據分析》（Wes McKinney著），還去圖書館借了本《Python數據分析基礎教程--N

Python學習（三） 八大排序算法的實現（下）

ram tty adjust 二叉樹 turn bre python 使用 元素 本文Python實現了插入排序、基數排序、希爾排序、冒泡排序、高速排序、直接選擇排序、堆排序、歸並排序的後面四種。 上篇：Python學習（三） 八大排序算法的實現（上）

RabbitMQ學習（二）工作隊列

lose borde 阻塞 lpad mes getc actor 使用 處理 1.工作隊列（Work Queue）又叫任務隊列（Task Queue）指將任務分發個多個消費者。 2.實際操作： 這裏使用一個生產者產生多條數據提供給3個消費者

RabbitMQ學習（六）：遠程結果調用

cells actor ble 隨機 get getenv all 求和 int 場景：我們需要在傳輸消息時得到結果 客服端在發送請求時會發送回調隊列，服務端處理事情完成後會將結果返回到回調隊列中，在增加關聯標誌關聯每個請求和服務返回 客戶端代碼： public