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