用户注册



邮箱:

密码:

用户登录


邮箱:

密码:
记住登录一个月忘记密码?

发表随想


还能输入:200字

rainyday123    -  云代码空间

——

kafka消息服务平台实现

2018-01-05|128阅||

摘要:JEESZ-kafka消息服务平台实现

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消息服务平台实现
愿意了解框架技术或者源码的朋友直接求求:2042849237
顶 0踩 0收藏
分享到:
更多
文章评论
    发表评论

    个人资料

    • 昵称: rainyday123
    • 等级: 资深程序员
    • 积分: 1960
    • 代码: 0 个
    • 文章: 62 篇
    • 随想: 0 条
    • 访问: 4 次
    • 关注

    人气代码

      标签

      MVC(7)Spring(4)J2EE分布式架构(1)分布式缓存Redis(1)+mybatis(5)+shiro+(2)Activiti(2)+(4)dubbo(1)springmvc(1)java企业架构(1)(十三)(2)(十四)(2)(十五)(1)kafka集群安装(1)springmvc,(1)阿里云OSS存储(1)Centos下单节点(1)Redis分布式缓存(1)单点登录集成方案,s(1)KafKa+Zook(1)JEESZ-kafk(1)spring,spr(1)mvc,web开发,(1)FastDFS安装、(1)FastDFS分布式(1)Zookeeper集(1)RestFul服务介(1)Kafka入门经典教(1)30分钟学会如何使用(1)springmvc+(1)分布式消息Kafka(1)如何实现redis缓(1)手把手Maven搭建(1)分布式服务:spri(1)Dubbo+Zook(1)分布式架构sprin(1)Springmvc+(1)j2ee分布式架构核(1)DUBBO与ZOOK(1)springmvc整(1)spring和spr(1)J2EE分布式系统环(1)MVC原理(1)Springmvc+(1)环境搭建(一)(1)入门示例讲解(1)【分享】微服务分布式(1)Springmvc+(1)(一)构建dubbo(1)(二)构建dubbo(1)(三)构建dubbo(1)(四)构建sprin(1)(五)构建sprin(1)springmvc+(1)restful(2)redis分布式缓存(1)【分享】微服务分布式(1)Springmvc+(1)(十六)(1)(十七)(1)【企业级框架整合】S(1)springmvc+(1)redis分布式缓存(1)构建springmv(1)构建springmv(1)构建dubbo分布式(1)构建dubbo分布式(1)springmvc+(1)dubbo分布式平台(1)分布式架构sprin(1)分布式服务:spri(1)Dubbo+Zook(1)dubbo分布式平台(1)dubbo分布式平台(1)【分享】微服务分布式(1)Springmvc+(1)Springmvc+(1)j2ee分布式架构核(1)构建springmv(1)构建springmv(1)构建dubbo分布式(1)构建dubbo分布式(1)构建springmv(1)构建dubbo分布式(1)DUBBO与ZOOK(1)构建dubbo分布式(1)

      最新提问

        站长推荐