一、簡介
在微服務架構的系統中，我們通常會使用輕量級的消息代理來構建一個共用的消息主題讓系統中所有微服務實例都連接上來，由於該主題中產生的消息會被所有實例監聽和消費，所以我們稱它為消息總線。
二、消息代理
消息代理(Message Broker)是一種消息驗證、傳輸、路由的架構模式。它在應用程序之間起到通信調度並最小化應用之間的依賴的作用，使得應用程序可以高效地解耦通信過程。消息代理是一個中間件產品，它的核心是一個消息的路由程序，用來實現接收和分發消息， 並根據設定好的消息處理流來轉發給正確的應用。 它包括獨立的通信和消息傳遞協議，能夠實現組織內部和組織間的網絡通信。設計代理的目的就是為了能夠從應用程序中傳入消息，並執行一些特別的操作，下面這些是在企業應用中，我們經常需要使用消息代理的場景：
目前已經有非常多的開源產品可以供大家使用， 比如：
三、SpringCloud+RabbitMQ
（1）RabbitMQ簡介、安裝不贅述。
（2）pom.xml
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
（3）application.yml
spring: application: name: rabbitmq-hello rabbitmq: host: ***.***.***.*** port: 5672 username: guest password: guest
（4）發送者Sender
@Component public class Sender { private static final Logger log = LoggerFactory.getLogger(Sender.class); @Autowired private AmqpTemplate amqpTemplate; public void send() { String context = "hello " + new Date(); log.info("Sender : " + context); this.amqpTemplate.convertAndSend("hello", context); } }（5）接受者Receiver
@Component @RabbitListener(queues = "hello") public class Receiver { private static final Logger log = LoggerFactory.getLogger(Receiver.class); @RabbitHandler public void process(String hello) { log.info("Receiver : " + hello); } }（6）創建RabbitMQ的配置類RabbitConfig
@Configuration public class RabbitConfig { @Bean public Queue helloQueue(){ return new Queue("hello"); } } （7）創建單元測試類， 用來調用消息生產
@RunWith(SpringJUnit4ClassRunner.class) @SpringBootTest(classes = SpringcloudbusrabbitmqApplication.class) public class HelloApplicationTests { @Autowired private Sender sender; @Test public void hello() throws Exception { sender.send(); } } （8）測試，執行HelloApplicationTests
（9）訪問host:15672
四、改造Config-Client（整合springcloud bus）
（1）pom.xml
<dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
（2）bootstrap.properties
spring.application.name=configspace spring.cloud.config.label=master spring.cloud.config.profile=dev spring.cloud.config.uri= http://localhost:5588/ eureka.client.serviceUrl.defaultZone=http://localhost:5555/eureka/ server.port=5589 spring.rabbitmq.host=118.89.237.88 spring.rabbitmq.port= 5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest management.security.enabled=false
（3）其他不用改變
五、測試
（1）測試準備
一個服務註冊中心，EUREKASERVER，端口為5555；
一個分佈式配置中心，ConfigServer，端口為5588；
二個分佈式配置，ConfigClient，端口為5589、5590；（2）訪問http://localhost:5589/from
（3）訪問http://localhost:5590/from
RabbitMQ：
（4）去倉庫修改password的值
from=git-dev-v1.0 by springcloud config-server username=springcloud password=1234567890
（5）POST請求http://localhost:5589/bus/refresh或者http://localhost:5590/bus/refresh
成功請求後config-client會重新讀取配置文件
（6）再次訪問
如果POST請求的是：http://localhost:5590/bus/refresh，請訪問http://localhost:5589/from
另/bus/refresh接口可以指定服務，即使用“username”參數，比如“/bus/refresh?destination=username:**”即刷新服務名為username的所有服務，不管ip地址。
（7）架構
（8）架構調整
既然SpringCloud Bus的/bus/refresh接口提供了針對服務和實例進行配置更新的參數，那麼我們的架構也可以相應做出一些調整。在之前的架構中，服務的配置更新需要通過向具體服務中的某個實例發送請求，再觸發對整個服務集群的配置更新。雖然能實現功能，但是這樣的結果是，我們指定的應用實例會不同千集群中的其他應用實例，這樣會增加集群內部的複雜度，不利於將來的運維工作。比如， 需要對服務實例進行遷移，那麼我們不得不修改Web Hook中的配置等。所以要盡可能地讓服務集群中的各個節點是對等的。
因此， 我們將之前的架構做了一些調整， 如下圖所示：
主要做了以下這些改動：
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。