前提：1、kafka版本1.0.12、在linux中使用kinit刷新kerberos认证信息/在配置文件中配置keytab路径和票据 1、生产者1.1、准备jaas.conf并添加到环境变量（使用以下方式的其中一种）1.1.1、使用Kinit方式前提是手动kinit 配置内容为： KafkaCli ...
分类：
其他好文 时间：
2019-06-17 10:36:29
阅读次数：
216
//程序演进1 //thread loop，忙等Busy wait //不断的检查是不是该做什么事情了；为了减少CPU占用，sleep睡眠一会 //while (1) //{ // do_something(); // sleep(time); //} //程序演进2 //while (1) //{... ...
分类：
编程语言 时间：
2019-06-16 17:29:51
阅读次数：
116
从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体。 Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。 Binding：绑定，它的作用就是把 ...
分类：
其他好文 时间：
2019-06-16 00:23:36
阅读次数：
98
1：kafka可以通过多个broker形成集群，来存储大量数据；而且便于横向扩展。 2：kafka信息存储核心的broker，通过partition的segment只关心信息的存储，而生产者只负责向leader角色的partition提交数据，而消费者pull数据的时候自己通过zk存储offset信 ...
分类：
其他好文 时间：
2019-06-15 00:16:48
阅读次数：
150
```go package main import ( "fmt" "time" ) func main() { // 管道 固定5个int ch := make(chan int, 5) // 生成者 协程 // 管道只能存5个int， 但是要生产15个int, 这就要等消费者先消费完（未消费前生 ...
分类：
其他好文 时间：
2019-06-14 16:41:46
阅读次数：
110
常用函数式接口与Stream API简单讲解 Stream简直不要太好使啊！！！ 常用函数式接口 ,主要方法： ,这是一个生产者，可以提供一个T对象。 ,主要方法： ,这是一个消费者，默认方法： ，稍后执行。 ,主要方法： ,这是一个判断者，默认方法： ：且， ：或， ：非。 ,主要方法： ,这是一 ...
Conditon中的await()对应Object的wait()，Condition中的signal()对应Object的notify()，Condition中的signalAll()对应Object的notifyAll() 两个线程交替执行例子（同理生产者消费者也是这样交替执行）： 运行结果： c ...
分类：
其他好文 时间：
2019-06-14 01:07:21
阅读次数：
84
消息队列主要分为两种，分别是生产者消费者模式和发布者订阅者模式，这两种模式 Redis 都支持。
分类：
其他好文 时间：
2019-06-12 11:21:21
阅读次数：
79
事故背景： 我们公司与合作方公司有个消息同步的需求，合作方是消息生产者，我们是消息消费者，他们通过kafka给我们推送消息，我们实时接收，然后进行后续业务处理。昨天上午，发现他们推送过来的广场门店信息我们都没有消费，导致我们系统和他们系统数据不一致，从而导致无法提单，无法出报表（报表有误）等各种问题 ...
分类：
其他好文 时间：
2019-06-12 10:53:36
阅读次数：
143
Eureka的服务器段使用springcloud(二)中的eureka_service 一. 因为使用一个注册中心服务器端，n个客户端：生产者客户端、消费者客户端....,所有的客户端最好的方式就是通过对象传递参数，因此需要创建一个公共组件项目，为n个客户端传值提供方便 二、创建公共组件项目 1.创 ...
分类：
编程语言 时间：
2019-06-11 13:29:29
阅读次数：
1279
