前言：
使用者的請求相當於生產者，消費者相當於我們的後台處理，qpid伺服器主要有以下兩個功能：
（1）生產者的生產的訊息按照規則進入相關的佇列裡
（2）將各個佇列裡的訊息分發到對應的各個消費者
說簡單一點，就是10000個使用者發出10000個相同的請求，佇列裡就會有10000個訊息（先進先出），qpid伺服器按照某種特定規則將10000個訊息分發到100個消費者進行消費處理，也就是每個消費者處理100個請求，從而提高併發，實現集群。
一、伺服器qpid broker 的安裝與使用
解壓即可，開啟bin目錄下的qpid-server.bat即可開啟伺服器。
關於建立佇列：
關於繫結主題：
**如下：
public class receive ");
//建立消費者
messageconsumer consumer = session.createconsumer(queue);
//點對點模式，只接收一次
//mapmessage m = (mapmessage)consumer.receive();
//監聽模式，
consumer.setmessagelistener(new messagelistener()
});//執行緒阻塞
system.in.read();
system.out.println("關閉連線");
connection.close();
}
**如下：
public class sender ");
//建立指定佇列乙個生產者
messageproducer producer = session.createproducer(queue);
//建立訊息
mapmessage m = session.createmapmessage();
m.setobject("diko","zjf，我喜歡你！");
//傳送訊息
producer.send(m);
//斷開連線
connection.close();}}
SpringBoot連線Redis集群
redis.clients jedis server.port 100 redis集群節點資訊 spring.redis.cluster.nodes 192.168.25.132 6379,192.168.25.132 6380,192.168.25.133 6379,192.168.25.133 ...
SpringBoot整合kafka集群
本文整合基於springboot2.0 kafka版本kafka 2.12 2.3.0，使用org.springframework.kafka來做的整合 專案目錄結構 pom.xml依賴 本配置檔案是才用的併發批量消費方式，bootstrap servers是我們集群的機器位址 生產者control...
spring boot 繼承redis集群
1.使用redis連線池 package com.yjw.config import org.springframework.beans.factory.annotation.autowired import org.springframework.context.annotation.bean i...