2. 程式人生 > >解決mq訊息一致性-訊息中介軟體(一)

解決mq訊息一致性-訊息中介軟體(一)

阿新 • • 發佈：2019-01-23

定義:產生訊息的業務動作和訊息傳送的一致。
如果業務動作執行成功了，那麼這個動作產生的訊息一定要傳送出去。另一方面，如果這個業務沒有發生或者失敗，就不應該把訊息傳送出去。

執行具體流程

  • 業務處理應用先把訊息傳送給訊息中介軟體,標記訊息狀態為待處理
  • 訊息中介軟體將訊息儲存在訊息儲存中,不投遞該訊息
  • 訊息中介軟體返回訊息處理的結果(入庫的結果)
  • 根據訊息中介軟體返回的結果操作.
    • 結果失敗,放棄業務處理
    • 結果成功,進行業務自身的操作
  • 業務操作完成,把業務操作的結果傳送給訊息中介軟體
  • 訊息中介軟體根據業務的結果操作
    • 業務失敗,刪除訊息儲存中的訊息
    • 業務成功,更新訊息儲存中訊息的狀態為可傳送.

相關推薦

解決mq訊息一致性-訊息中介軟體(一)

定義:產生訊息的業務動作和訊息傳送的一致。 如果業務動作執行成功了，那麼這個動作產生的訊息一定要傳送出去。另一方面，如果這個業務沒有發生或者失敗，就不應該把訊息傳送出去。 執行具體流程 業務處理應用先把訊息傳送給訊息中介軟體,標記訊息狀態為待處理 訊息中

20181104-訊息中介軟體(一)-ActiveMQ安全認證和持久化

一、ActiveMQ安全認證 1.在conf/activemq.xml中開啟認證，即在broker標籤中新增以下程式碼 <plugins> <!-- use JAAS to authenticate using t

JMS|訊息中介軟體(一)簡介

１什麼是訊息中介軟體 　　訊息中介軟體利用高效可靠的訊息傳遞機制進行平臺無關的資料交流，並基於資料通訊來進行分散式系統的整合。通過提供訊息傳遞和訊息排隊模型，它可以在分散式環境下擴充套件程序間的通訊。對於訊息中介軟體，常見的角色大致也就有 Producer（生

從零開發分散式資料庫中介軟體 一、讀寫分離的資料庫中介軟體

  在傳統的單機體系中，我們在操作資料庫時，只需要直接得到資料庫的連線，然後操作資料庫即可，可是在現在的資料爆炸時代，只靠單機是無法承載如此大的使用者量的，即我們不能縱向擴充套件，那麼我們就只能水平進行擴充套件，即使用讀寫分離的主從資料庫來緩解資料庫的壓力，而在讀寫分離之後

訊息中介軟體（一）分散式系統事務一致性解決方案大對比，誰最好使？（轉）

原文轉載至：https://blog.csdn.net/lovesomnus/article/details/51785108   在分散式系統中，同時滿足“一致性”、“可用性”和“分割槽容錯性”三者是不可能的。分散式系統的事務一致性是一個技術難題，各種解決方案孰優孰劣？ 在OLTP系統領域，

訊息中介軟體（一）分散式系統事務一致性解決方案大對比，誰最好使？

在分散式系統中，同時滿足“一致性”、“可用性”和“分割槽容錯性”三者是不可能的。分散式系統的事務一致性是一個技術難題，各種解決方案孰優孰劣？ 在OLTP系統領域，我們在很多業務場景下都會面臨事務一致性方面的需求，例如最經典的Bob給Smith轉賬的案例。傳統的企業開發，

訊息中介軟體保證訊息一致性解決方案

1、訊息中介軟體的應用場景 (1)非同步通訊 (2)解耦 (3)併發緩衝 2、訊息傳送和投遞的不可靠性 (1)分散式網路進行就引入了資料傳輸的不確定性 (2)也就是CAP理論中的P（分割槽容錯性） (3)跨網路通訊產生了分散式事務問題 3、訊息傳

訊息中介軟體MQ（一）概念及常識

1.概念和用途：Message Queue顧名思義就是訊息佇列。打個比方去快餐店點餐，每個人點餐可能只要10s，但如果三個人同時向服務員點餐，服務員就可能會亂了，三個顧客還可能會吵起來，這件事就沒法30s內解決，那麼很簡單，排隊點餐就好辦了。所以MQ最核心的功能

訊息中介軟體--RabbitMQ學習（一）

Activemq介紹 Activemq是 Apache出品,最流行的能力強勁的開源訊息匯流排,並且它個完全支援MS規範的訊息中介軟體。 其豐富的AP、多種叢集構建模式使得他成為業界老牌訊息中介軟體,在中小型企業中應用廣泛。 MQ衡量指標:服務效能、資料儲存、叢集架構

Kafka-API中介軟體MQ訊息佇列在Maven專案中的配置使用操作 (分散式釋出訂閱訊息系統)

一、 Maven依賴 <dependency> <groupId>com.foriseland.fjf.mq</groupId> <artifactId>fjf-mq-kafka</artifactId> &

【轉】【選型】【MQ】訊息中介軟體對比

https://blog.csdn.net/huayushuangfei/article/details/80866642    訊息中介軟體對比 為什麼選擇RocketMQ 價效比，社群活躍度  價效比之“性”：  效能：阿里支撐，經受住淘寶，

MQ訊息中介軟體

MQ是什麼？ MQ是Message Queue訊息佇列的縮寫。訊息佇列是一種應用程式對應用程式的通訊方法、應用程式通過寫和檢索入列隊的針對應用程式的資料（訊息）來進行通訊，而不需要專用連線來連結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊，而不是通過直接呼叫彼此來通訊，直接呼叫通常是用於諸如遠端

訊息中介軟體入門「一」:初識訊息中介軟體【ActiveMQ】

訊息中介軟體入門「一」:初識訊息中介軟體【ActiveMQ】 背景介紹 訊息中介軟體相當於程序間通訊的信託，可以降低複雜系統中各個模組間的耦合度。對於信託：你只需要把Message給我，就沒你的事兒了。我負責給你送到目的地，就不需要你必須實時的守著，等待所有通訊細節的完成。

【分散式架構】分散式訊息中介軟體MQ開發教程

關於分散式訊息中介軟體MQ的詳細介紹： 【分散式架構】分散式訊息中介軟體MQ開發教程 （阿里雲訊息佇列MQ（Message Queue）是企業級網際網路架構的核心產品，服務於整個阿里巴巴集團已超過8年，經過阿里巴巴交易核心鏈路反覆打磨與歷年雙十一嚴苛考驗，是一個真正具備低延遲、高併發、高可用

訊息中介軟體解決方案-JMS-ActiveMQ

一、JMS入門 　　1.1 JMS簡介 　　JMS是Java平臺上有關面向訊息中介軟體的技術規範，它本身只定義了一系列的介面規範，是一種與廠商無關的API，用來訪問訊息收發系統。訊息是JMS中的一種型別物件，由兩部分組成：報頭和訊息主體。報頭由路由資訊以及有關該訊息的元資料組成。訊息主體則攜帶者應用程式的

flink叢集一鍵安裝指令碼 -- kafka訊息中介軟體依賴zookeeper叢集安裝指令碼

#!/bin/sh INSTALL_PATH="/usr/local/src/"; ZOOKEEPER_VERSION="3.4.11" ZOOKEEPER_GZIP="zookeeper-${ZOOKEEPER_VERSION}.tar.gz"; ZOOKEEPER_CONF_DIR

訊息佇列中介軟體（一）介紹

訊息佇列中介軟體（一）介紹 訊息佇列介紹 訊息佇列中介軟體是大型系統中的重要元件，已經逐漸成為企業系統內部通訊的核心手段。它具有鬆耦合、非同步訊息、流量削峰、可靠投遞、廣播、流量控制、最終一致性等一系列功能，已經成為非同步RPC的主要手段之一。 目前常見的訊息中介軟體有ActiveMQ、Ra

訊息中介軟體ActiveMQ（一）HelloWorld入門例項

1、JMS訊息傳送模式 在點對點或佇列模型： 一個生產者向一個特定的佇列釋出訊息，一個消費者從該佇列中讀取訊息。這裡，生產者知道消費者的佇列，並直接將訊息傳送到消費者的佇列。這種模式被概括為：只有一個消費者將獲得訊息。生產者不需要在接收者消費該訊息期間處於執行狀態，接收

訊息中介軟體MQ（二）模式、應用場景、常用協議

1.訊息中介軟體模式分類 1.1 點對點 1.2釋出/訂閱 2訊息中介軟體應用場景 2.1非同步通訊 有些業務不想也不需要立即處理訊息。訊息佇列提供了非同步處理機制，允許使用者把一個訊息放入佇列，但並不立即處理它。想向佇列中放入多少訊息就放多少，然後在需要的

訊息中介軟體MQ（三）JMS常識及簡單案例

1JMS概念 JMS即Java訊息服務（Java Message Service）應用程式介面，是一個Java平臺中關於面向訊息中介軟體（MOM）的API，用於在兩個應用程式之間，或分散式系統中傳送訊息，進行非同步通訊。Java訊息服務是一個與具體平臺無關的AP