ReadFromJDQ3 1）消费JDQ的必要信息，通过参数传入，有6个参数 2）获取flink JDQ3的鉴权客户端 3）根据鉴权客户端获取消费属性的配置 4）构建应用环境ENV和checkpoint机制 5）构建JDQ3（基于kafka）对应的消费客户端，flink用来消费实时订单消息 6) 根 ...
分类：
其他好文 时间：
2019-10-12 11:06:54
阅读次数：
106
1.问题业务上新增一条订单记录，用户接收到BinLake拉取的MySQL从库数据消息后，马上根据消息内的订单号去查询同一个MySQL从库，发现有些时候无法查到该条数据，等待大约500ms～1000ms后再去查询数据库，可以查询到该条数据。注:BinLake为京东商城数据库技术部自研的一套订阅和消费MySQL数据库binlog的组件，本例所描述的问题是业务方希望根据订阅的binlog来获取实时订单等
分类：
其他好文 时间：
2018-11-29 17:54:40
阅读次数：
243
维护socket长连接虽然很耗电，但是却有广泛的用途。如：网络电话，实时接单的应用等。
由于服务器域名固定，手机客户端的网络IP可能不断变更，服务器一般想主动找手机客户端想说声不容易。运营商发现手机经常不用网络时（大部分省份判断手机客户端最近30分钟内是否使用流量，来判断你的手机是否在用网络，若有流量就不把你IP分给别人），会把你的手机以前使用的IP分配给其它手机号,所有苹果把苹果手机网络定义为不...
分类：
其他好文 时间：
2015-08-29 21:47:52
阅读次数：
166
