立即注册
查看: 1054|回复: 2

[原创] JEESZ-kafka消息服务平台实现

已绑定手机
发表于 2018-7-20 14:57:40 | 显示全部楼层 |阅读模式 来自 广东省惠州市

jeesz的消息服务平台已经抛弃了之前的ActiveMQ,改用高吞吐量比较大的Kafka分布式消息中间件方案:

JEESZ-kafka消息平台使用spring+kafka的集成方案,详情如下:

1. 使用最高版本2.1.0.release集成jar包:spring-integration-kafka

2. ZooKeeper、Kafka分布式集群使用init.properties配置化方案。

3. 使用消息生产者spring-context-producer配置化方案。

4. 使用消息消费者spring-context-producer配置化方案。

5. 使用注解方式注入消息类型

@Autowired

private KafkaTemplate kafkaTemplate;

6. 重写messagelistener 的getMessage方法获取消息(业务实现)

7. RestFul服务方式测试消息服务

接受消息了------------------:ConsumerRecord(topic = xxxooo, partition = 0, offset = 2489, CreateTime = 1479647648299, checksum = 3372898135, serialized key size = -1, serialized value size = 40, key = null, value = Hello JEESZ分布式系统发过来的消息)

kafka-1.png

已绑定手机
 楼主| 发表于 2018-7-20 14:59:44 | 显示全部楼层 来自 广东省惠州市
欢迎大家一起交流~~
已绑定手机
发表于 2022-8-26 06:37:09 | 显示全部楼层 来自 浙江省杭州市
学习一下
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

合作/建议

TEL: 19168984579

工作时间:
周一到周五 9:00-11:30 13:30-19:30
  • 扫一扫关注公众号
  • 扫一扫打开小程序
Copyright © 2013-2024 一牛网 版权所有 All Rights Reserved. 帮助中心|隐私声明|联系我们|手机版|粤ICP备13053961号|营业执照|EDI证
在本版发帖搜索
扫一扫添加微信客服
QQ客服返回顶部
快速回复 返回顶部 返回列表