2. 程式人生 > >訊息佇列中介軟體（二）使用 ActiveMQ

訊息佇列中介軟體（二）使用 ActiveMQ

阿新 • • 發佈：2018-12-11

ActiveMQ 介紹

Active MQ 是由 Apache 出品的一款流行的功能強大的開源訊息中介軟體，它速度快，支援跨語言的客戶端，具有易於使用的企業整合模式和許多的高階功能，同時完全支援 JSM1.1 和 J2EE1.4 。

ActiveMQ 特點

  • 支援Java，C，C ++，C＃，Ruby，Perl，Python，PHP等各種跨語言客戶端和協議，如 OpenWire , Stomp , AMQP , MQTT.
  • 完全支援JMS 1.1和 J2EE 1.4，支援瞬態，持久，事務和XA訊息傳遞。
  • 對 Spring 框架的支援以便ActiveMQ可以輕鬆嵌入到Spring應用程式中。
  • 通過了常見的 J2EE 伺服器測試，如 TomEE，Geronimo，JBoss，GlassFish 和 WebLogic 。
  • 連線方式的多樣化，ActiveMQ 提供了多種連線模式，例如 in-VM、TCP、SSL、NIO、UDP、多播、JGroups、JXTA。
  • 可以通過使用 JDBC 和 journal 實現訊息的快速持久化。
  • 專為高效能群集，客戶端 - 伺服器，點對點通訊而設計。
  • 提供與語言無關的 REST API。
  • 支援 Ajax 方式呼叫 ActiveMQ。
  • ActiveMQ 可以輕鬆地與 CXF、Axis 等 Web Service 技術整合，以提供可靠的訊息傳遞。
  • 可用作為記憶體中的 JMS 提供者，非常適合 JMS 單元測試。

ActiveMQ 訊息

  1. 點對點佇列模式
    訊息到達訊息系統，被保留在訊息佇列中，然後由一個或者多個消費者消費佇列中的訊息，一個訊息只能被一個消費者消費，然後就會被移除。例如訂單處理系統。
  2. 釋出-訂閱模式
    訊息傳送時指定主題（或者說通道），訊息被保留在指定的主題中，消費者可以訂閱多個主題，並使用主題中的所有的訊息，例如現實中的電視與電視訊道。所有客戶端包括髮布者和訂閱者，主題中的訊息可以被所有的訂閱者消費，消費者只能消費訂閱之後傳送到主題中的訊息。

ActiveMQ 概念

  • Broker，訊息代理，表示訊息佇列伺服器實體，接受客戶端連線，提供訊息通訊的核心服務。
  • Producer，訊息生產者，業務的發起方，負責生產訊息並傳輸給 Broker 。
  • Consumer，訊息消費者，業務的處理方，負責從 Broker 獲取訊息並進行業務邏輯處理。
  • Topic，主題，釋出訂閱模式下的訊息統一彙集地，不同生產者向 Topic 傳送訊息，由 Broker 分發到不同的訂閱者，實現訊息的廣播。
  • Queue，佇列，點對點模式下特定生產者向特定佇列傳送訊息，消費者訂閱特定佇列接收訊息並進行業務邏輯處理。
  • Message，訊息體，根據不同通訊協議定義的固定格式進行編碼的資料包，來封裝業務 資料，實現訊息的傳輸。

ActiveMQ 工程例項

下面是使用 ActiveMQ 的佇列模式和釋出-訂閱模式的 Java 程式碼示例。

POM 依賴

        <!-- Active-MQ -->
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.15.5</version>
        </dependency>

佇列模式消費者

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

/**
 * <p>
 * 訊息消費者，用於消費訊息
 *
 * @Author niujinpeng
 * @Date 2018/9/4 23:45
 */
public class AppConsumer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String queueName = "queue-test";

    public static void main(String[] args) throws JMSException {
        // 1.建立ConnectionFactory
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        // 2.建立Connection
        Connection connection = connectionFactory.createConnection();
        // 3.啟動連線
        connection.start();

        // 4.建立會話,false，不使用事務，自動應答模式
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 5.建立一個目標
        Destination destination = session.createQueue(queueName);
        // 6.建立消費者
        MessageConsumer consumer = session.createConsumer(destination);

        // 7.建立一個監聽器
        consumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println("接收訊息：" + textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });

        // 8.關閉連線
        //connection.close();
    }
}

佇列模式生產者

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

/**
 * <p>
 * 訊息提供者，用於向訊息中介軟體傳送訊息
 *
 * @Author niujinpeng
 * @Date 2018/9/4 23:28
 */
public class AppProducer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String queueName = "queue-test";

    public static void main(String[] args) throws JMSException {
        // 1.建立ConnectionFactory
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        // 2.建立Connection
        Connection connection = connectionFactory.createConnection();
        // 3.啟動連線
        connection.start();

        // 4.建立會話,false，不使用事務，自動應答模式
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 5.建立一個目標
        Destination destination = session.createQueue(queueName);
        // 6.建立生產者
        MessageProducer producer = session.createProducer(destination);

        // 7.建立訊息併發送
        for (int i = 0; i < 10; i++) {
            // 建立訊息
            TextMessage textMessage = session.createTextMessage("textMessage" + i);
            // 釋出訊息
            producer.send(textMessage);
            System.out.println("傳送訊息：" + textMessage.getText());
        }

        // 8.關閉連線
        connection.close();

    }
}

釋出訂閱模式生產者

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

/**
 * <p>
 * 主題模式
 * 訊息消費者，用於消費訊息
 *
 * @Author niujinpeng
 * @Date 2018/9/4 23:45
 */
public class AppConsumer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String topicName = "topic-test";

    public static void main(String[] args) throws JMSException {
        // 1.建立ConnectionFactory
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        // 2.建立Connection
        Connection connection = connectionFactory.createConnection();
        // 3.啟動連線
        connection.start();

        // 4.建立會話,false，不使用事務，自動應答模式
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 5.建立一個目標
        Destination destination = session.createTopic(topicName);
        // 6.建立消費者
        MessageConsumer consumer = session.createConsumer(destination);

        // 7.建立一個監聽器
        consumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println("接收訊息：" + textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });

        // 8.關閉連線
        //connection.close();
    }
}

釋出訂閱模式生產者

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

/**
 * <p>
 * 主題模式
 * 訊息提供者，用於向訊息中介軟體傳送訊息
 *
 * @Author niujinpeng
 * @Date 2018/9/4 23:28
 */
public class AppProducer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String topicName = "topic-test";

    public static void main(String[] args) throws JMSException {
        // 1.建立ConnectionFactory
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        // 2.建立Connection
        Connection connection = connectionFactory.createConnection();
        // 3.啟動連線
        connection.start();

        // 4.建立會話,false，不使用事務，自動應答模式
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 5.建立一個目標
        Destination destination = session.createTopic(topicName);
        // 6.建立生產者
        MessageProducer producer = session.createProducer(destination);

        // 7.建立訊息併發送
        for (int i = 0; i < 10; i++) {
            // 建立訊息
            TextMessage textMessage = session.createTextMessage("textMessage" + i);
            // 釋出訊息
            producer.send(textMessage);
            System.out.println("傳送訊息：" + textMessage.getText());
        }

        // 8.關閉連線
        connection.close();

    }
}

GitHub原始碼：https://github.com/niumoo/message-queue

Spring 整合 ActiveMQ

在 Spring 中配置 Active MQ 就像Spring 整合其他功能一樣，我們需要在 XML 配置中配置幾個關鍵的例項即可。在 Active MQ 中有幾個物件的例項是至關重要的，如 Active MQ jms 連線工廠，為了減少連線斷開效能時間消耗的 jms 連線池以及生產者消費者等。

下面是一些詳細說明。

  • ConnectionFactory 用於管理連線的連線工廠（Spring提供）。
    • 一個 Spring 為我們提供的連線池。
    • JmsTemplate 每次傳送都會重新建立連線，會話和 Productor。
    • Spring 中提供了SingleConnectionFactory 和CachingConnectionFactory（增加了快取功能）。
  • JmsTemplate 是用於傳送和接收訊息的模板類。
    • 是spring提供的，只需要向Spring 容器內註冊這個類就可以使用 JmsTemplate 方便的操作jms。
    • JmsTemplate 類是執行緒安全的，可以在整個應用範圍使用。
  • MessageListerner 訊息監聽器
    • 使用一個onMessage方法，該方法只接收一個Message引數。

POM 依賴

<properties>
        <spring.version>5.0.4.RELEASE</spring.version>
    </properties>
    <dependencies>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>5.1.1.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <!-- 這個版本的Spring需要使用JMS 2.0版本，但spring-jms的依賴沒有自動匯入JMS 2.0，而activemq-core會匯入JMS 1.1的依賴 -->
        <dependency>
            <groupId>javax.jms</groupId>
            <artifactId>javax.jms-api</artifactId>
            <version>2.0.1</version>
        </dependency>

        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-core</artifactId>
            <version>5.7.0</version>
            <exclusions>
                <exclusion>
                    <artifactId>spring-context</artifactId>
                    <groupId>org.springframework</groupId>
                </exclusion>
                <exclusion>
                    <groupId>org.apache.geronimo.specs</groupId>
                    <artifactId>geronimo-jms_1.1_spec</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

XML 配置

XML 公共配置

為了份檔案配置方便管理，下面是提取出來的公共配置，為了在獨立配置生產者和消費者 XML檔案時引入，當然也可以直接把生產者和消費者以及所有的 XML bean 配置在一個檔案裡。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:content="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <content:annotation-config/>

    <!-- ActiveMQ為我們提供的connection factory -->
    <bean id="targerConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://127.0.0.1:61616"/>
    </bean>

    <!-- spring jms為我們提供的連線池 -->
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <property name="targetConnectionFactory" ref="targerConnectionFactory"/>
    </bean>

    <!-- 一個佇列模式目的地（佇列名稱），點對點的訊息模式 -->
    <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="queue-spring"/>
    </bean>

    <!-- 一個主題模式目的地（主題名稱），釋出訂閱訊息模式 -->
    <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="topic-spring"/>
    </bean>

</beans>

XML 消費者

消費者主要是一個訊息監聽器，監聽指定的佇列或者主題的訊息資訊，來有訊息時呼叫回撥監聽處理方法。這裡我註釋掉了監聽的佇列模式，指定了主題模式。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:content="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!-- 匯入公共配置 -->
    <import resource="common.xml"/>

    <!-- 配置訊息監聽器 -->
    <bean id="consumerMessageListener" class="net.codingme.jms.consumer.ConsumerMessageListener"/>

    <!-- 配置訊息監聽容器 -->
    <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory"/>
        <!-- 佇列模式 -->
        <!--<property name="destination" ref="queueDestination"/>-->
        <!-- 主題模式 -->
        <property name="destination" ref="topicDestination"/>
        <property name="messageListener" ref="consumerMessageListener"/>
    </bean>

</beans>

XML 生產者

生成者的配置主要是使用 spring jms 模版物件，建立生產者例項用於生產訊息。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:content="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!-- 匯入公共配置 -->
    <import resource="common.xml"/>

    <!-- jms模版-->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>

    <bean class="net.codingme.jms.producer.ProducerServiceImpl"></bean>

</beans>

生產者編寫

1. 定義介面

package net.codingme.jms.producer;

/**
 * <p>
 *
 * @Author niujinpeng
 * @Date 2018/11/2518:19
 */
public interface ProducerService {
    public void sendMessage(String message);
}

2. 主題模式生產者

package net.codingme.jms.producer;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

import javax.annotation.Resource;
import javax.jms.*;


/**
 * <p>
 *
 * @Author niujinpeng
 * @Date 2018/11/25 19:24
 */
public class ProducerServiceImpl implements ProducerService {

    @Autowired
    JmsTemplate jmsTemplate;
    /**
     * 主題模式
     */
    @Resource(name = "topicDestination")
    Destination destination;

    @Override
    public void sendMessage(String message) {
        // 使用jmsTemplate傳送訊息
        jmsTemplate.send(destination, new MessageCreator() {
            // 建立訊息
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage textMessage = session.createTextMessage(message);
                return textMessage;
            }
        });
        System.out.println("傳送訊息：" + message);

    }
}

3. Spring 啟動 生產者

package net.codingme.jms.producer;

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * <p>
 * 啟動器
 *
 * @Author niujinpeng
 * @Date 2018/11/25 21:48
 */
public class AppProducer {

    public static void main(String[] args) {
        // 裝載配置檔案
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:producer.xml");
        ProducerService service = context.getBean(ProducerService.class);

        for (int i = 0; i < 10; i++) {
            service.sendMessage("test" + i);
        }
        context.close();
    }

}

消費者編寫

Spring啟動和生產者類似。下面是消費者監聽器的實現。

package net.codingme.jms.consumer;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**
 * <p>
 * 訊息監聽器
 *
 * @Author niujinpeng
 * @Date 2018/11/25 22:28
 */
public class ConsumerMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println("接收訊息：" + textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

執行測試

首先主題模式下啟動兩個消費者，使用生產者推送10條訊息。

測試

在每個消費者下面都可以看到推送的完整訊息。

測試

文中程式碼已經上傳到GitHub：https://github.com/niumoo/message-queue

<完>
本文原發於個人部落格：https://www.codingme.net 轉載請註明出處

相關推薦

訊息佇列中介軟體（二）使用 ActiveMQ

ActiveMQ 介紹 Active MQ 是由 Apache 出品的一款流行的功能強大的開源訊息中介軟體，它速度快，支援跨語言的客戶端，具有易於使用的企業整合模式和許多的高階功能，同時完全支援 JSM1.1 和 J2EE1.4 。 官方下載地址： http://activemq.apache.or

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

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

訊息佇列中介軟體（三）Kafka 入門指南

Kafka 來源 Kafka的前身是由LinkedIn開源的一款產品，2011年初開始開源，加入了 Apache 基金會，2012年從 Apache Incubator 畢業變成了 Apache 頂級開源專案。同時LinkedIn還有許多著名的開源產品。如： 分散式資料同步系統Databus

訊息中介軟體（二）訊息佇列常見的幾種使用場景介紹

一、訊息佇列概述 訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題。實現高效能，高可用，可伸縮和最終一致性架構。是大型分散式系統不可缺少的中介軟體。 目前在生產環境，使用較多的訊息佇列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaM

分散式訊息中介軟體（一）——ActiveMQ點對點訊息模式

一、下載執行 1、官網下載      Windows版：apache-activemq-5.13.3-bin.zipLinux版：apache-activemq-5.13.3-bin.tar.gz 2、Windows下根據作業系統位數，執行activemq.bat檔案，啟動

徹底搞懂Scrapy的中介軟體（二）

在上一篇文章中介紹了下載器中介軟體的一些簡單應用，現在再來通過案例說說如何使用下載器中介軟體整合Selenium、重試和處理請求異常。 在中介軟體中整合Selenium 對於一些很麻煩的非同步載入頁面，手動尋找它的後臺API代價可能太大。這種情況下可以使用Selenium和ChromeDriver或者Se

RabbitMQ訊息佇列系列教程（二）Windows下安裝和部署RabbitMQ

摘要 本篇經驗將和大家介紹Windows下安裝和部署RabbitMQ訊息佇列伺服器，希望對大家的工作和學習有所幫助！ 目錄 一、Erlang語言環境的搭建 RabbitMQ開源訊息佇列服務是使用Erlang語言開發的，因此我們要使用他就必須先進行Erlang語言環境的搭建，其實是非常簡

mycat中介軟體（二）linux版本mycat1.6版本安裝

前言 前面的文章，介紹了關於mycat的相關概念，為了簡要描述，故而去掉了有關mycat的起源等內容。 本節內容則是講述，如何安裝mycat1.6版本。 安裝前環境要求 環境要求如下: 環境 版本 mysql

C# Queue與RabbitMQ的愛恨情仇（文末附原始碼）：Q與MQ訊息佇列簡單應用（二）

上一章我們講了佇列（ Queue），這一章我們講Message Queue訊息佇列，簡稱MQ。 定義： 　　MQ是MessageQueue，訊息佇列的簡稱（是流行的開源訊息佇列系統，利用erlang語言開發）。MQ是一種應用程式對應用程式的通訊方法。 應用程式通過讀寫入隊和出隊的訊息來通訊，無

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

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

【Android自助餐】Handler訊息機制完全解析（二）MessageQueue的佇列管理

Android自助餐Handler訊息機制完全解析（二）MessageQueue的佇列管理 Android自助餐Handler訊息機制完全解析二MessageQueue的佇列管理 新增到訊息佇列enqueueMessage 從佇

使用訊息中介軟體（RabbitMQ）來收集資料

一 新建專案microservice-consumer-movie-ribbon-hystrix-turbine-mq二 為專案新增依賴 <dependency> <

中介軟體--訊息中介軟體（一）應用背景和場景

背景： 應用整合面臨的幾個問題： 1.網路是不可靠的 2.分散式下網路的速度不足夠的快 3.任何兩端的應用可能是不同的，應用實現方式、語言，不同資料格式等 4.應用隨著需求改變難以避免，整合的

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

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

分散式訊息中介軟體（六）——Kafka核心元件詳解

一、Kafka釋出訂閱訊息系統基礎      Kafka 是分散式釋出-訂閱訊息系統。它最初由 LinkedIn 公司開發，使用 Scala語言編寫,之後成為 Apache 頂級專案框架。Kafka

分散式訊息中介軟體（四）——Flume+Kafka+Storm+Redis生態架構實戰

一、Kafka專案應用架構分析 1、Kafka生態架構        資料收集的速度，跟處理的速度不一定一致，故使用Kafka中介軟體作為資料收集和資料處理的一個Access入口，接收flume收集的資料，並通過kafkaSpout提交給Storm進行處理。 2、kafka

ActiveMQ使用筆記（二）ActiveMQ訊息持久化一

<persistenceAdapter>   <mKahaDB directory="${activemq.base}/data/kahadb">     <filteredPersistenceAdapters>       <!-- match all queu

Redis實現中介軟體（訂閱）

什麼是訊息中介軟體 釋出訂閱 點對點   訊息中介軟體本身是非同步的通訊 案例：使用redis實現釋出訂閱功能 Redis釋出訂閱   Redis 釋出訂閱(pub/sub)是一種訊息通訊模式：傳送者(pub)傳送訊息，訂閱者(sub)接收訊息。 Redis 客戶端可以

訊息佇列中介軟體？？

  訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題 二、訊息佇列應用場景 以下介紹訊息佇列在實際應用中常用的使用場景。非同步處理，應用解耦，流量削鋒和訊息通訊四個場景 2.1非同步處理 場景說明：使用者註冊後，需要發註冊郵件和註冊簡訊。傳統的做法有兩

Delayer 基於 Redis 的延遲訊息佇列中介軟體

Delayer 基於 Redis 的延遲訊息佇列中介軟體，採用 Golang 開發，支援 PHP、Golang 等多種語言客戶端。 參考 有贊延遲佇列設計 中的部分設計，優化後實現。 專案連結：https://github.com/mixstart/d... ，有需要的朋友加 Star 哦。 應用場景