Java架構-spring+springmvc+kafka分散式訊息中介軟體整合方案
Honghu的訊息服務平臺已經拋棄了之前的ActiveMQ，改用高吞吐量比較大的Kafka分散式訊息中介軟體方案：
kafka訊息平臺使用spring+kafka的整合方案，詳情如下：
-
使用最高版本2.1.0.RELEASE整合jar包：spring-integration-kafka
-
Zookeeper、Kafka分散式叢集使用init.properties配置化方案。
Java程式碼
-
使用訊息消費者spring-context-producer配置化方案。
Java程式碼
- 使用註解方式注入訊息型別
@Autowired
private KafkaTemplate<xxx, ooo> kafkaTemplate;
-
重寫MessageListener 的getMessage方法獲取訊息（業務實現）
-
RestFul服務方式測試訊息服務
Java程式碼
Java程式碼
接受訊息了------------------:ConsumerRecord(topic = xxxooo, partition = 0, offset = 2489, CreateTime = 1479647648299, checksum = 3372898135, serialized key size = -1, serialized value size = 40, key = null, value = HongHu KAFKA分散式訊息服務測試)
到此結束！
我這邊會將近期研發的spring cloud微服務雲架構的搭建過程和精髓記錄下來，幫助更多有興趣研發spring cloud框架的朋友，大家來一起探討spring cloud架構的搭建過程及如何運用於企業專案。
我本人邀約各大BATJ架構大牛共創Spring Cloud構建微服務架構的交流社群。 （群號：573988200）歡迎各路架構師、開發者，學習與交流使用Spring Cloud諸多強大元件的實戰經驗。
為什麼某些人會一直比你優秀，是因為他本身就很優秀還一直在持續努力變得更優秀，而你是不是還在滿足於現狀內心在竊喜!
合理利用自己每一分每一秒的時間來學習提升自己，不要再用"沒有時間“來掩飾自己思想上的懶惰！趁年輕，使勁拼，給未來的自己一個交代！
希望此文能幫到大家的同時，也聽聽大家的觀點。歡迎留言討論，加關注，分享你的高見！持續更新！
To-陌霖Java架構
分享網際網路最新文章 關注網際網路最新發展