码迷,mamicode.com
首页 >  
搜索关键字:consumer高级特性之独有消费者(exclusive consumer)    ( 1435个结果
为什么阿里巴巴Java开发手册中强制要求不要在foreach循环里进行元素的remove和add操作?
在阅读《阿里巴巴Java开发手册》时,发现有一条关于在 foreach 循环里进行元素的 remove/add 操作的规约,具体内容如下: 错误演示 我们首先在 IDEA 中编写一个在 foreach 循环里进行 remove 操作的代码: 此时执行代码,编译正确,执行成功!输出 [wupx, hu ...
分类:编程语言   时间:2019-12-03 01:23:34    阅读次数:108
Kafka 消费者 Demo
import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.con... ...
分类:其他好文   时间:2019-12-01 23:08:23    阅读次数:203
Pulsar 消息概念1
Pulsar官方文档概念和架构-MessagingConcepts中主要内容1消息组成|组成|说明||--------|--------||Value/datapayload|消息携带的数据,所有pulsar的消息携带原始bytes,但是消息数据也需要遵循数据shcema||Key|消息可以被Key打标签。这可以对topic压缩之类的事情起作用||Properties|用户定义属性的可选键/值映射
分类:其他好文   时间:2019-11-29 19:45:59    阅读次数:200
SpringBoot整合kafka(实现producer和consumer)
本文代码使用的是Spring Boot 2.1.8.RELEASE 版本 1、 pom.xml文件,引入依赖 采用Kafka提供的StringSerializer和StringDeserializer进行序列化和反序列化 2、在application-dev.properties配置生产者 3、生产 ...
分类:编程语言   时间:2019-11-28 16:27:49    阅读次数:102
PHP实现QQ第三方登录代码
前言: PHP实现QQ快速登录,罗列了三种方法 方法一:面向过程,回调地址和首次触发登录写到了一个方法页面【因为有了if做判断】, 方法二,三:面向对象 1.先调用登录方法,向腾讯发送请求,2.腾讯携带本网站唯一对应参数OPENID,ACCESSTOKEN,返回到对应回调页面,3.回调页面接受到腾讯 ...
分类:Web程序   时间:2019-11-28 13:28:16    阅读次数:96
kafka 集群环境搭建与管理
上一篇展示了kafka虚拟机环境单机版部署,这一节主要讲kafka集群环境部署,kafka基础概念介绍与强化1)Producer:消息生产者,就是向kafkabroker发消息的客户端;2)Consumer:消息消费者,向kafkabroker取消息的客户端;3)Topic:可以理解为一个队列;4)ConsumerGroup(CG):这是kafka用来实现一个topic消息的广播(发给所有的con
分类:其他好文   时间:2019-11-27 13:48:09    阅读次数:77
动手造轮子:实现简单的 EventQueue
最近项目里有遇到一些并发的问题,想实现一个队列来将并发的请求一个一个串行处理,可以理解为使用消息队列处理并发问题,之前实现过一个简单的 `EventBus`,于是想在 `EventBus` 的基础上改造一下,加一个队列,改造成类似消息队列的处理模式。消息的处理(Consumer)直接使用 .netc... ...
分类:其他好文   时间:2019-11-24 11:38:13    阅读次数:57
Java中多线程通信怎么实现
线程通信的方式: 1、共享变量 线程间通信可以通过发送信号,发送信号的一个简单方式是在共享对象的变量里设置信号值。线程A在一个同步块里设置boolean型成员变量hasDataToProcess为true,线程B也在同步代码块里读取hasDataToProcess这个成员变量。这个简单的例子使用了一 ...
分类:编程语言   时间:2019-11-22 01:06:15    阅读次数:77
深入理解Kafka必知必会(2)
"深入理解Kafka必知必会(1)" Kafka目前有哪些内部topic,它们都有什么特征?各自的作用又是什么? __consumer_offsets:作用是保存 Kafka 消费者的位移信息 __transaction_state:用来存储事务日志消息 优先副本是什么?它有什么特殊的作用? 所谓的 ...
分类:其他好文   时间:2019-11-22 00:53:53    阅读次数:58
springboot使用dubbo和zookeeper
2019 11 17 yls 创建服务接口模块 接口工程只提供接口,不提供实现,在后面的提供者和消费者中使用 在使用接口的模块中只需要写具体实现类,避免了在每个模块中重复编写接口 1. 在接口中引入依赖包 2. 创建一个实体类,一定要实现Serializable接口,否则dubbo协议之间无法传输 ...
分类:编程语言   时间:2019-11-18 12:56:07    阅读次数:76
1435条   上一页 1 ... 29 30 31 32 33 ... 144 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!