REPORT YTEST_WEBSERVICE_N . DATA LS_CONSUMER TYPE REF TO ZCL_CO_ZWS_ZPPT006M . DATA LS_INPUT TYPE ZCL_ZWS_ZPPT006M . DATA LS_OUTPUT TYPE ZCL_ZWS_ZPPT0... ...
分类：
Web程序 时间：
2019-09-30 09:18:59
阅读次数：
101
匿名内部类 匿名内部类在日常编程中还是经常会使用的。比如 lamda 是java 8的新特性。配合java8的stream流处理，特别的方便 java里还有一个函数接口，在编写中也会用lamda去表示，这样简单一点 + Function + Consumer + Predicate + Suppli ...
分类：
其他好文 时间：
2019-09-29 23:55:11
阅读次数：
200
一、broker参数 broker.id：kafka集群的唯一标识。 log.dirs：kafka存储消息日志的目录，多个用逗号隔开，需要保证指定的目录有充足的磁盘空间。 zookeeper.connect：必须配置，指定kafka集群注册的zookeeper集群的地址。格式是：[主机名]:端口，多 ...
分类：
其他好文 时间：
2019-09-29 12:54:03
阅读次数：
366
异步队列的实现。 如下图所示 这里的异步实现，采用redis作为单向的任务队列，将事件通过序列存入redis队列，通过反序列化将其发送给事件消费者。 事件消费者，通过一个EventHandler接口，来处理不同的事件。 事件分发器通过向jedisqueue lpush事件，consumer 从jed ...
分类：
其他好文 时间：
2019-09-28 00:48:16
阅读次数：
115
目录 简介 accept方法 andThen方法 经典应用 iterable 扩展类介绍 简介 Consumer是一个函数式接口，它有一个需要覆盖的方法accept，代表接受一个参数输入且没有任何返回值的操作。不同于其它的函数式接口，Consumer期望通过方法的实现来执行具体的操作。 accept ...
分类：
编程语言 时间：
2019-09-26 14:57:42
阅读次数：
110
你可以不关闭防火墙，只需要开启这些端口就行了MASTER节点6443* Kubernetes API server 2379-2380 etcd server client API 10250 Kubelet API 10251 kube-scheduler 10252 kube-controlle ...
分类：
其他好文 时间：
2019-09-26 12:02:33
阅读次数：
200
使用python操作kafka目前比较常用的库是kafka python库 安装kafka python 生产者 producer_test.py 执行此程序，它没有输出！这个是正常的 消费者 执行此程序，此时会hold住，因为它在等待生产者发送消息！ 再次执行生产者，此时会输出： ...
分类：
编程语言 时间：
2019-09-24 17:57:52
阅读次数：
106
上一篇，使用了Feign的熔断器Hystrix，去对Consumer进行了改造，使其拥有了对服务异常的处理能力。 接下来要做对服务的访问情况进行监控 Hystrix-dashboard 熔断监控，在实际集群中同服务的节点有许多个，这里仅作单个服务节点的监控，集群中的监控会在下一篇有讲 对消费者Con ...
分类：
编程语言 时间：
2019-09-24 13:54:47
阅读次数：
85
基于队列实现生产者与消费者模型 上述代码中解决办法缺点：如果有N个消费者，是否还要生产者put进去N个None呢？ 用JoinableQueue 解决消费者结束问题 是不是晕了，那就对了，代码执行顺序： 1、consumer 中把对列中所有的任务消耗完 q.task_done() 2、produce ...
分类：
编程语言 时间：
2019-09-21 18:48:26
阅读次数：
86
1、先在电脑（win 7 或 Win 10）安装华为手机助手https://consumer.huawei.com/minisite/HiSuite_cn/，然后升级到最新版。2、点击链接在网盘下载ABD工具包pan.baidu.com/s/1R00_eqeD5fDf-oBxXAvejQ，解压缩放在 ...
分类：
移动开发 时间：
2019-09-21 15:15:28
阅读次数：
181
