:-: 
生產消費過程
**1. 聲明隊列與交換機的綁定關系**
```java
@Configuration
public class RabbitConfig {
public final static String THREE_EXCHAGE = "three.exchange";
public final static String JUPITER_QUEUE = "jupiter.queue";
public final static String SATURN_QUEUE = "saturn.queue";
public final static String JUPITER_MIDDLE_KEY = "*.jupiter.*";
public final static String SATURN_PREFIX_KEY = "saturn.*";
public final static String SATURN_SUFIX_KEY = "*.saturn";
/**
* 創建Topic交換機
*/
@Bean("threeExchange")
public TopicExchange threeExchange() {
return new TopicExchange(THREE_EXCHAGE);
}
/**
* 創建jupiter隊列
*/
@Bean("jupiterQueue")
public Queue jupiterQueue() {
return new Queue(JUPITER_QUEUE);
}
/**
* 創建saturn隊列
*/
@Bean("saturnQueue")
public Queue saturnQueue() {
return new Queue(SATURN_QUEUE);
}
/**
* jupiter隊列與交換機綁定
*/
@Bean
public Binding jupiterBinding(@Qualifier("jupiterQueue") Queue queue,
@Qualifier("threeExchange") TopicExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(JUPITER_MIDDLE_KEY);
}
/**
* saturn隊列與交換機綁定,key=SATURN_PREFIX_KEY
*/
@Bean
public Binding saturn01Binding(@Qualifier("saturnQueue") Queue queue,
@Qualifier("threeExchange") TopicExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(SATURN_PREFIX_KEY);
}
/**
* saturn隊列與交換機綁定,key=SATURN_SUFIX_KEY
*/
@Bean
public Binding saturn02Binding(@Qualifier("saturnQueue") Queue queue,
@Qualifier("threeExchange") TopicExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(SATURN_SUFIX_KEY);
}
}
```
**2. 生產者**
```java
@Slf4j
@RestController
public class ProducerController {
@Autowired
private RabbitTemplate rabbitTemplate;
@RequestMapping("/topic/produce")
public void topicProduce() {
Map<String, Object> msgBody = new HashMap<>(16);
msgBody.put("name", "zhangsan");
msgBody.put("age", 25);
msgBody.put("key", "easy.jupiter.yes");
//convertAndSend(String exchange, String routingKey, Object object)
rabbitTemplate.convertAndSend(RabbitConfig.THREE_EXCHAGE, "easy.jupiter.yes", msgBody);
log.info("topicProduce[生產了消息]:{}", msgBody);
msgBody.put("key", "saturn.world");
rabbitTemplate.convertAndSend(RabbitConfig.THREE_EXCHAGE, "saturn.world", msgBody);
log.info("topicProduce[生產了消息]:{}", msgBody);
msgBody.put("key", "much.saturn");
rabbitTemplate.convertAndSend(RabbitConfig.THREE_EXCHAGE, "much.saturn", msgBody);
log.info("topicProduce[生產了消息]:{}", msgBody);
}
}
```
**3. 消費者**
```java
@Slf4j
@Service
public class ConsumerService {
/**
* 監聽jupiter隊列
*/
@RabbitListener(queues = RabbitConfig.JUPITER_QUEUE)
public void jupiterConsume(Message<Map<String, Object>> message, Channel channel) {
Map<String, Object> msgBody = message.getPayload();
log.info("jupiterConsume[收到了消息]:{}", msgBody);
}
/**
* 監聽saturn隊列
*/
@RabbitListener(queues = RabbitConfig.SATURN_QUEUE)
public void saturnConsume(Message<Map<String, Object>> message, Channel channel) {
Map<String, Object> msgBody = message.getPayload();
log.info("saturnConsume[收到了消息]:{}", msgBody);
}
}
```
**4. 測試結果**
```
: topicProduce[生產了消息]:{name=zhangsan, age=25, key=easy.jupiter.yes}
: topicProduce[生產了消息]:{name=zhangsan, age=25, key=saturn.world}
: topicProduce[生產了消息]:{name=zhangsan, age=25, key=much.saturn}
: jupiterConsume[收到了消息]:{name=zhangsan, age=25, key=easy.jupiter.yes}
: saturnConsume[收到了消息]:{name=zhangsan, age=25, key=saturn.world}
: saturnConsume[收到了消息]:{name=zhangsan, age=25, key=much.saturn}
```
- 跨域問題
- 跨域是什么
- 跨域解決方案
- 從后端解決
- nginx反向代理
- WebSocket
- websocket是什么
- websocket協議
- 使用場景
- 實現方式
- 注解與html5原生方式
- websocketAPI
- 實現步驟
- 文件上傳
- 文件下載
- 廣播通信
- 定時推送
- 編程與socketjs方式
- socketjs與stompjs框架
- 實現步驟
- 重載目的地
- SimpMessagingTemplate
- 定時向前端推送數據
- 5種監聽事件
- 點對點通信
- 攔截器
- HandshakeInterceptor
- ChannelInterceptor
- poi之excel表格
- 表格版本
- POI常用類
- POI依賴
- 寫表格
- 編寫表格過程
- 單元格邊框樣式
- 單元格背景色
- 凍結行或列
- 單元格合并
- 單元格內換行
- 文檔內跳轉
- 讀表格
- Web中的Excel操作
- 導出表格
- 讀取表格
- poi之word文檔
- word版本
- 寫word
- 基本使用
- 標題樣式
- 添加圖片
- EasyExcel表格
- EasyExcel是什么
- 與其他Excel工具對比
- EasyExcel依賴
- 讀Excel
- 簡單讀取
- 指定列位置
- 讀取多個sheet
- 格式轉換
- 多行表頭
- 同步讀
- 寫Excel
- 簡單寫入
- 單元格樣式
- 攔截器
- 列寬
- 凍結行或列
- 合并單元格
- 填充Excel
- SpringSecurity
- SpringSecurity是什么
- 同類型產品對比
- 環境搭建
- 相關概念
- 密碼加密
- Web權限控制
- UserDetailsService接口
- 登錄認證
- 自定義登錄頁
- 未授權跳轉登錄頁
- 權限控制
- 自定義403頁面
- 權限注解
- 記住我功能
- 注銷功能
- CSRF
- CSRF是什么
- CSRF保護演示
- 前后端分離權限控制
- 環境搭建
- 認證實現
- 會話管理
- 動態權限管理
- 微服務權限控制
- 權限控制方案
- SpringBoot整合RabbitMQ
- 整合步驟
- Fanout交換機演示
- Direct交換機演示
- Topic交換機演示
- @RabbitListener方法
- JWT認證與授權
- 環境搭建
- 密碼加密
- 認證與授權