文档章节

bboss kafka组件使用介绍

yin_bp
 yin_bp
发布于 2017/07/22 15:31
字数 380
阅读 6
收藏 1
点赞 0
评论 0

bboss kafka组件使用介绍
本文使用的实例对应的gradle源码工程git访问地址:
http://git.oschina.net/bboss/bestpractice
testkafka子工程地址
http://git.oschina.net/bboss/bestpractice/tree/master/testkafka

1.导入bboss kafka组件
maven坐标

<dependency>
    <groupId>com.bbossgroups.plugins</groupId>
    <artifactId>bboss-plugin-kafka</artifactId>
    <version>5.0.3.1</version>
</dependency>

gradle坐标

compile 'com.bbossgroups.plugins:bboss-plugin-kafka:5.0.3.1'

2.使用kafka producer,发送消息
2.1 kafka producer配置
编写kafka.xml配置文件,放到classpath跟路径下面

相关配置说明:
bootstrap.servers kafka服务器地址配置
value.serializer kafka消息序列化插件配置
key.serializer kafka消息key序列化插件配置
f:sendDatatoKafka="true" 是否启动消息发送功能,false 禁用,true 启用

2.2 发送kafka消息

发送kafka消息相关组件:
org.frameworkset.plugin.kafka.KafkaUtil
org.frameworkset.plugin.kafka.KafkaProductor

KafkaUtil组件加载配置文件并获取KafkaProductor ,通过KafkaProductor 发送kafka消息

3.接收和处理kafka消息
3.1 kafka consumer配置
新建kafkaconsumer.xml文件,放到classpath根路径下面

配置说明:
storeService 配置消息处理组件
zookeeper.connect 配置管理kafka服务器和消息的zookeeper集群地址
f:topic="blackcat" 消费的kafka topic
f:partitions="4" topic对应的分区数,决定并行处理消息的工作线程

3.2 接收和处理消息
接收和处理消息相关组件:
org.frameworkset.plugin.kafka.KafkaConsumer
org.frameworkset.plugin.kafka.StoreService

编写消息处理组件,处理组件需要实现接口
org.frameworkset.plugin.kafka.StoreService
public void store(MessageAndMetadata<byte[], byte[]> message)  throws Exception ;
public void closeService();

StoreServiceTest实现:

3.3 加载kafka consumer配置并启动消息接收线程

BaseApplicationContext context = DefaultApplicationContext.getApplicationContext("kafkaconfumer.xml");
		KafkaConsumer consumer = context.getTBeanObject("kafkaconsumer", KafkaConsumer.class);
		Thread t = new Thread(consumer);
		t.start();

 

© 著作权归作者所有

共有 人打赏支持
yin_bp
粉丝 2
博文 2
码字总数 458
作品 0
长沙
开源框架 bboss v5.0.2.9 发布

开源框架bboss v5.0.2.9发布 新增功能特性和功能改进: 1.持久层增加公共sql片段配置及引用功能,参考文档: bboss持久层公共sql片段定义和引用方法说明 2.完善http通用组件,支持多个http连...

bboss ⋅ 2017/04/26 ⋅ 1

bboss v5.0.3.6 发布,企业级 J2EE 开源框架

bboss v5.0.3.6发布 功能改进 1.将log4j日志组件调整为slf4j,可以根据需要选择项目需要的日志组件(log4j,log4j2,logback等) 2.改进和优化http服务组件,增加delete服务接口和json报文发送...

bboss ⋅ 2017/08/17 ⋅ 0

企业级J2ee开源框架 - bboss

bboss是一个j2ee开源框架,为企业级应用开发提供一站式解决方案,并能有效地支撑移动应用开发。bboss功能涵盖ioc,mvc,jsp自定义标签库,持久层,全局事务托管,安全认证,SSO,web会话共享...

bboss ⋅ 2010/03/19 ⋅ 3

高性能Elasticsearch ORM开发库bboss es 5.0.3.7.8发布

bboss es v5.0.3.7.8已发布。bboss elasticsearch是一套基于query dsl语法操作访问分布式搜索引擎elasticsearch的o/r mapping开发库,底层基于es restful api。使用bboss es,可以快速编写出...

bboss ⋅ 2017/11/16 ⋅ 4

bboss session v5.0.3.1 发布,会话共享和监控框架

bboss session v5.0.3.1 发布,bboss session为web应用提供session共享和 session监控管理功能。 主要功能特性: 支持集群session共享 支持跨域跨应用session共享 提供强大的统一session管理...

bboss ⋅ 2017/08/17 ⋅ 2

bboss v5.0.0 发布,J2EE 企业级开源框架

J2EE企业级开源框架bboss v5.0.0 发布。 v5.0.0是bboss有史以来最稳定、功能最全版本,完全兼容之前版本功能。全面采用gradle构建和发布版本,并将版本提交到maven中央库。可以在github获取b...

bboss ⋅ 2016/07/05 ⋅ 6

bboss 快速开发平台--bboss-pdp

平台的基本功能和特点: 基于角色的权限管理(操作、菜单、url) 组织机构、人员、角色、 个人账户管理和口令修改、密码重置 资源管理 日志管理 菜单管理 基于bootstrap ui布局 字典管理 SS...

bboss ⋅ 2017/10/28 ⋅ 2

bboss 自动代码生成框架 v4.10 发布

bboss自动代码生成框架v4.10发布,针对bboss框架和bboss开发平台的自动代码生成工具。 通过自动代码生成框架,根据模板可以自动生成数据库表的增、删、改、分页查询、列表查询、国际化功能对应...

bboss ⋅ 2015/10/29 ⋅ 12

bboss特色及项目下载地址

bboss是一个j2ee开源框架,为企业级应用开发提供一站式解决方案,并能有效地支撑移动应用开发。bboss功能涵盖ioc,mvc,jsp自定义标签库,持久层,全局事务托管,安全认证,SSO,web会话共享...

bboss ⋅ 2014/11/17 ⋅ 4

bbossgroups-3.0 发布,新增子项目bboss mvc

bbossgroups-3.0发布 release version : bbossgroups-3.0 release date: 2011/02/26 主要的功能特性: 1.新增的一套mvc框架即bboss-mvc子项目,这是bbossgroups-3.0相比bbossgroups-2.0-RC1......

小编辑 ⋅ 2011/02/28 ⋅ 2

没有更多内容

加载失败,请刷新页面

加载更多

下一页

RabbitMQ学习以及与Spring的集成(三)

本文介绍RabbitMQ与Spring的简单集成以及消息的发送和接收。 在RabbitMQ的Spring配置文件中,首先需要增加命名空间。 xmlns:rabbit="http://www.springframework.org/schema/rabbit" 其次是模...

onedotdot ⋅ 23分钟前 ⋅ 0

JAVA实现仿微信红包分配规则

最近过年发红包拜年成为一种新的潮流,作为程序猿对算法的好奇远远要大于对红包的好奇,这里介绍一种自己想到的一种随机红包分配策略,还请大家多多指教。 算法介绍 一、红包金额限制 对于微...

小致dad ⋅ 34分钟前 ⋅ 0

Python 数电表格格式化 xlutils xlwt xlrd的使用

需要安装 xlutils xlwt xlrd 格式化前 格式化后 代码 先copy读取的表格,然后按照一定的规则修改,将昵称中的学号提取出来替换昵称即可 from xlrd import open_workbookfrom xlutils.copy ...

阿豪boy ⋅ 今天 ⋅ 0

面试题:使用rand5()生成rand7()

前言 读研究生这3 年,思维与本科相比变化挺大的,这几年除了看论文、设计方案,更重要的是学会注重先思考、再实现,感觉更加成熟吧,不再像个小P孩,人年轻时总会心高气傲。有1 道面试题:给...

初雪之音 ⋅ 今天 ⋅ 0

Docker Toolbox Looks like something went wrong

Docker Toolbox 重新安装后提示错误:Looks like something went wrong in step ´Checking if machine default exists´ 控制面板-->程序与应用-->启用或关闭windows功能:找到Hyper-V,如果处......

随你疯 ⋅ 今天 ⋅ 0

Guacamole 远程桌面

本文将Apache的guacamole服务的部署和应用,http://guacamole.apache.org/doc/gug/ 该链接下有全部相关知识的英文文档,如果水平ok,可以去这里仔细查看。 一、简介 Apache Guacamole 是无客...

千里明月 ⋅ 今天 ⋅ 0

nagios 安装

Nagios简介:监控网络并排除网络故障的工具:nagios,Ntop,OpenVAS,OCS,OSSIM等开源监控工具。 可以实现对网络上的服务器进行全面的监控,包括服务(apache、mysql、ntp、ftp、disk、qmail和h...

寰宇01 ⋅ 今天 ⋅ 0

AngularDart注意事项

默认情况下创建Dart项目应出现以下列表: 有时会因为不知明的原因导致列表项缺失: 此时可以通过以下步骤解决: 1.创建项目涉及到的包:stagehand 2.执行pub global activate stagehand或pub...

scooplol ⋅ 今天 ⋅ 0

Java Web如何操作Cookie的添加修改和删除

创建Cookie对象 Cookie cookie = new Cookie("id", "1"); 修改Cookie值 cookie.setValue("2"); 设置Cookie有效期和删除Cookie cookie.setMaxAge(24*60*60); // Cookie有效时间 co......

二营长意大利炮 ⋅ 今天 ⋅ 0

【每天一个JQuery特效】淡入淡出显示或隐藏窗口

我是JQuery新手爱好者,有时间就练练代码,防止手生,争取每天一个JQuery练习,在这个博客记录下学习的笔记。 本特效主要采用fadeIn()和fadeOut()方法显示淡入淡出的显示效果显示或隐藏元...

Rhymo-Wu ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部