1. 程式人生 > >RocketMQ入門(5.單向(Oneway)傳送)

RocketMQ入門(5.單向(Oneway)傳送)

原理:單向(Oneway)傳送特點為只負責傳送訊息,不等待伺服器迴應且沒有回撥函式觸發,即只發送請求不等待應答。此方式傳送訊息的過程耗時非常短,一般在微秒級別。

應用場景:適用於某些耗時非常短,但對可靠性要求並不高的場景,例如日誌收集。


生產者

package yangjiachang.mq.producter;
import com.aliyun.openservices.ons.api.*;
import java.util.Properties;
/**
 * Created by yangjiachang on 2016/8/12.
 */
public class OnewayProducerTest {

    public static void 
main(String[] args) { Properties properties = new Properties(); properties.put(PropertyKeyConst.AccessKey, "rIa4vosh93cvU79x");// AccessKey 阿里雲身份驗證,在阿里雲伺服器管理控制檯建立 properties.put(PropertyKeyConst.SecretKey, "Cp3Mqo0UgqbLfRU5dSCboxLHei73M8");// SecretKey 阿里雲身份驗證,在阿里雲伺服器管理控制檯建立 properties.put(PropertyKeyConst.ProducerId
, "PID_YJC_DEMO_02");//您在控制檯建立的Producer ID properties.setProperty(PropertyKeyConst.SendMsgTimeoutMillis, "3000");//設定傳送超時時間,單位毫秒 Producer producer = ONSFactory.createProducer(properties); // 在傳送訊息前,必須呼叫start方法來啟動Producer,只需呼叫一次即可。 producer.start(); //迴圈傳送訊息 Message msg = new Message( // Message Topic
"yjc_mq_demo", // Message Tag, // 可理解為Gmail中的標籤,對訊息進行再歸類,方便Consumer指定過濾條件在MQ伺服器過濾 "demo4", // Message Body // 任何二進位制形式的資料,MQ不做任何干預,需要ProducerConsumer協商好一致的序列化和反序列化方式 "Hello MQ-Async".getBytes()); // 設定代表訊息的業務關鍵屬性,請儘可能全域性唯一。 // 以方便您在無法正常收到訊息情況下,可通過阿里雲伺服器管理控制檯查詢訊息並補發。 // 注意:不設定也不會影響訊息正常收發 msg.setKey("demo004"); // oneway傳送訊息,只要不拋異常就是成功 producer.sendOneway(msg); // 在應用退出前,銷燬Producer物件 // 注意:如果不銷燬也沒有問題 producer.shutdown(); } }

jar包依賴和客戶端程式碼和其他傳送方式一致,具體程式碼地址如下:

相關推薦

RocketMQ入門5.單向Oneway傳送

原理:單向(Oneway)傳送特點為只負責傳送訊息,不等待伺服器迴應且沒有回撥函式觸發,即只發送請求不等待應答。此方式傳送訊息的過程耗時非常短,一般在微秒級別。 應用場景:適用於某些耗時非常短,但對可

快速入門Python3.5開發1

1 Python快速入門課程介紹與環境搭建 知識點: Python3.5環境搭建 基本型別 型別轉換 演示: Python 3.5.1 (v3.5.1:37a07cee596

linux centos7下原始碼 tar安裝mysql5.7.235.7以上均可試用

1、工具:mysql-5.7.22-linux-glibc2.12-x86_64.tar.gz、centos7 2、解壓後,將mysql-5.7.22-linux-glibc2.12-x86_64裡面的東西放到 /usr/local/mysql資料夾下 3、新增系統mysql組和mysql使用者

linux centos7下源碼 tar安裝mysql5.7.235.7以上均可試用

connect -s ice 安裝 oca 參考 tar centos7 改密碼 1、工具:mysql-5.7.22-linux-glibc2.12-x86_64.tar.gz、centos7 2、解壓後,將mysql-5.7.22-linux-glibc2.12-x86_

【資料結構】單鏈表無頭單向非迴圈連結串列各個介面的實現

順序表存在的問題: 中間/頭部的插入刪除,時間複雜度為O(N) 增容需要申請新空間,拷貝資料,釋放舊空間。會有不小的消耗 增容一般是呈2倍的增長,勢必會有一定的空間浪費。 例如當前容量為100,滿了以後增容到200,如果再繼續插入了5個數據,後面沒有資料插入了,

pandas21 讀csv檔案read_csv5.文字資料讀寫例項詳細 tcy

例項 2018/12/27 目錄: 第1部分:csv文字檔案讀寫 pandas 讀csv檔案read_csv(1.文字讀寫概要)https://mp.csdn.net/postedit/85289371 pandas 讀csv檔案read_csv(2.read_csv引數介紹)

c語言 寫一個函式,輸入n,求斐波拉契數列的第n項5種方法,層層優化

                寫一個函式,輸入n,求斐波拉契數列的第n項。 斐波拉契數列:1,1,2,3,5,8...,當n

Redis 基礎知識5種資料型別基本操作

1、字串 set key1value1  //value1不僅可以是字串,也可以是整數或者浮點數。 get key1                     //獲取值 del key1              //刪除值 既然value1可以為數值型,因此可以對key1

c語言:寫一個函式,輸入n,求斐波拉契數列的第n項5種方法,層層優化

寫一個函式,輸入n,求斐波拉契數列的第n項。斐波拉契數列:1,1,2,3,5,8...,當n大於等於3時,後一項為前面兩項之和。解:方法1:從斐波拉契數列的函式定義角度程式設計#include<stdio.h>int fibonacci(int n){int nu

樹莓派ASCII指令串列埠通訊十六進位制傳送

對於指令文字 ENQ STX 08 PS 0500 F0 ETX的ASCII傳送 首先按照我上一篇部落格開啟串列埠 >>ser.write("\x05\x02\x30\x38\x50\x53\x20\x20\x30\x35\x30\x30\x46\x30\x0

Android麥克風錄音的實現手動實現環信音訊傳送

最近公司有一個業務,就是通過IM傳送音訊,我用的是環信的第三方,自定義傳送音訊,寫了一個錄音的demo,錄製完成之後傳送。 這個Demo測試之後感覺還不錯,分享一下。 一、新增許可權: <uses-permission android:name="android.p

網絡構建入門技術5——子網劃分應用

掩碼 -1 參考資料 臺電 www 說明 網絡 com hive 說明(2017-5-16 11:27:00): 題目: 一個公司有530臺電腦,組成一個對等局域網,子網掩碼和IP設多少最合適? 1. 首先選IP地址類別,A類太多,C類不夠用,就選B類了,假設為188.18

maven入門5使用eclipse構建maven項目

org 菜單欄 ini tag 界面 java 我們 core comm 1. 安裝m2eclipse插件 要用Eclipse構建Maven項目,我們需要先安裝meeclipse插件 點擊eclipse菜單欄Help->Eclipse Marketplac

Python編程入門到實踐 - 筆記 5

python if 判斷 第 5 章練習了以下內容簡單的 if 判斷語句判斷字符串是否相等,還是不等進行數字的大小比較and,or 比較檢查列表中是否存在指定的元素if,if-else,if-elif-else 語句寫法if 判斷列表是否為空使用多個列表進行比較判斷這一章的內容也比較簡單,感覺和

JDBC入門5--- 時間類型、大數據

服務器 setting fun exceptio finall trace rep rest bytes 一、時間類型 數據庫類型與Java中類型的對應關系: DATE->java.sql.Date:表示日期,只有年月日,沒有時分秒,會丟失時間。 TIME->j

MATLAB入門學習-#5-M檔案MATLAB程式基礎

MATLAB入門學習-#5-M檔案(MATLAB)程式基礎 1.was ist M檔案... 2.程式控制結構 3.函式檔案! 正式開始之前,先來兩個學習中學到的小TIP: 1.matlab程式中,中括號內容一般都是可以省略的東西。

大資料入門5配置ssh免密登陸

登陸的115 1、使用ssh登陸     ssh  192.168.1.116      輸入密碼     登陸成功     退出:exit 2、

RocketMQ學習筆記5----RocketMQ監控平臺rocketmq-console-ng的搭建

1. 下載rocketmq-console-ng   官網地址:https://github.com/apache/rocketmq-externals      拉下來之後,使用idea開啟rocketmq-console,在application.properties配置檔案中修改rocketmq.

React從入門到架構5--基於Antd專案,認識React的State

從上一節React從入門到架構(4)–基於Antd專案,初探React的Props後,我們已經認識了props的作用,主要用於父元件和子元件之間的資料傳遞。 這一節介紹一下state。 先明確一個概念: 和props不同的是,state表示的是狀態。 【屬性】是依賴於外部的資料傳遞; 而

Robot Framework - 入門與操作5

大小 解析 one 令行 放置 數量 通關 ngs 兩種 Creating test data ***** Test suites 測試集沒有測試用例個數的限制,但建議不要超過 10 個測試用例。 除非是使用數據驅動模式,這種模式的測試用例僅包含一個高級別關鍵字。 測試