天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的
這幾年除了手機作為智能生活終端最主要的核心之外，第二個可以成為中心點的產品是什么？——是智能音箱。 手機在執行命令的時候有兩種操作方式，手和智能語音助手，而智能音箱只
2018 年，做為架構負責人，接到一個架構需求：實現一個簡單易用的 RocketMQ SDK 。
因為各個團隊 RocketMQ 原生客戶端配置起來千奇百怪，有的配置存在風險，各團隊負責人都需要一個簡潔易用的 RocketMQ SDK 。
我立馬調研相關開源的方案，當時 RocketMQ-Spring 項目并沒有開源，而阿里云的 ONS SDK 是開源的，我只能講目標轉向 阿里云 ONS 。
通過學習 ONS 的設計方式，我對于 RocketMQ 的客戶端原理有了進一步了解，也實現了公司內部使用的 RocketMQ SDK 。
圖片
項目地址：https://github.com/makemyownlife/platform-rocketmq
之所以說簡單，就是讓用戶（開發者）使用 SDK 時，減少心智負擔。
舉三個例子：
使用原生代碼發送消息時，會使用如下的代碼：
SendResult sendResult = producer.send(msg, new MessageQueueSelector() { @Override public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) { Integer id = (Integer) arg; int index = id % mqs.size(); return mqs.get(index); }}, orderId);我們可以將 SDK API 簡化為：
SendResult send(final ProducerMessage message, final String shardingKey);開發者不需要定義隊列選擇器，只需要傳遞分片鍵 orderId 即可。
使用原來代碼定義消費監聽器時，使用如下的代碼：
consumer.registerMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) { System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); // 返回消息消費狀態，ConsumeConcurrentlyStatus.CONSUME_SUCCESS為消費成功 return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }});監聽器內部，對于開發者操作的對象是消息列表 msgs ，很多開發同學想只操作一條消息。
于是，我們可以將 SDK API 簡化為：
consumer.subscribe("mytest", new ConsumerListener() { @Override public ConsumerAction consumer(ConsumerMessage msg) { byte[] body = msg.getBody(); System.out.println("msg:" + new String(body)); return ConsumerAction.CommitMessage; }});開發者在消費時，可以一條一條操作，代碼簡潔了不少。
同時，很多開發者在使用普通消費、順序消費時，需要返回延時消費的狀態碼時，兩種消費模式定義的枚舉也不相同。我們將枚舉做了統一：
/** * 消費消息的返回結果 */public enum ConsumerAction { /** * 消費成功，繼續消費下一條消息 */ CommitMessage, /** * 消費失敗，告知服務器稍后再投遞這條消息，繼續消費其他消息 */ ReconsumeLater;}實際場景里，訂閱關系不一致是極容易發生的事情，就算是高級別的架構師也會翻車，每次翻車現場都是慘不忍睹。
正確的訂閱關系見下圖：
圖片
正確的訂閱關系
代碼邏輯角度來看，每個消費者實例內訂閱方法的主題、 TAG、監聽邏輯都需要保持一致。
圖片
當訂閱關系不一致時，在 Broker 端同一個消費組內的各個消費者客戶端的訂閱信息相互被覆蓋，從而導致某個消費者客戶端無法拉取到新的消息。
怎么解決呢 ？
我當時想起了阿里技術專家沈詢的一句話：
世界上解決一個計算機問題最簡單的方法：“恰好”不需要解決它 ！
公司內部出現訂閱關系一致99%的問題是：消費者組一致的前提下，主題相同，但 TAG 不相同。
基于此，我的設計思路就明確了：不開放訂閱 TAG 的權限！
沒想到吧，我就是這么粗暴。
按照這種設計思路，雖然開始有的程序員會有質疑，但你和他梳理好消費者組的定義，以及做好領域劃分，對業務來講，反而清晰了。
本文鏈接：http://www.www897cc.com/showinfo-26-87267-0.html如何實現一個簡單易用的 RocketMQ SDK
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： Tailwind 4.0 即將到來：前端開發的“速度與激情”
下一篇： Python Queue模塊全攻略
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號