如果不清楚本篇内容的，请务必先去看完上一篇再看本篇，否则阅读起来可能会有部分障碍和困难； 上一篇文章《SpringCloud学习之Stream消息驱动【默认通道】（十）》我们简单用自定义通道实现了消息发送和接收，但是用的是Stream给我们提供的默认Source，Sink，接下来我们要自己进行自定义 ...
分类：
编程语言 时间：
2020-01-18 18:06:41
阅读次数：
193
小米小爱蓝牙音箱--产品外观 小米小爱蓝牙音箱 - - 产品参数 蓝牙版本：4.2 工作距离：10 米 额定阻抗：4Ω 支持协议：A2DP ／ AVRCP ／ SPP / HFP / BLE 声频响范围：200Hz~18kHz（-10dB） 供电方式：内置锂电池 充电端口：Micro USB电池容量 ...
分类：
移动开发 时间：
2020-01-12 13:01:41
阅读次数：
952
阿里云 事件监控开源项目地址 https://github.com/AliyunContainerService/kube eventer 需要对一下变量进行修改 sink=dingtalk:[your_webhook_url]&label=[your_cluster_id]&level=[Norm ...
分类：
其他好文 时间：
2020-01-06 11:12:05
阅读次数：
139
10.9传输网(Transport network) 一些名词: 流量守恒(Conservation of flow) 除源点s(source)和宿点t(sink)之外，要求其他节点流入的流量和流出的流量相等 最大流(Maximal flow) 对于网络流图G，流量最大的可行流f，称为最大流 基本算 ...
分类：
Web程序 时间：
2020-01-05 18:29:17
阅读次数：
110
Flume采集的控制台提示：The channel is full or unexpected failure. The source will try again after 1000 ms 这个是因为当前被采集的文件过大，深层的原因是文件采集的速度和sink的速度没有匹配好。所以应该可以通过增大 ...
分类：
其他好文 时间：
2019-12-28 22:41:20
阅读次数：
335
详细代码及注释如下： xm=100;%设置区域为100*100 ym=100; sink.x=0.5*xm;%sink（汇聚）节点坐标 sink.y=1.75*ym; n=100 %区域内的节点数目 p=0.05;% 节点成为簇头的概率 Eo=0.5;%节点初始能量 ETX=50*0.0000000 ...
分类：
其他好文 时间：
2019-12-21 20:17:00
阅读次数：
94
topN功能是一个非常常见的功能，比如查看最近几分钟的阅读最高数，购买最高数。 flink实现topN的功能也非常方便，下面就开始构建一个flink topN的程序。 还是像上篇博客一样，从kafka读取数据，然后进行计算和数据转换，最后sink到mysql中。 假设有个需求，实现一个统计每5分钟最 ...
分类：
其他好文 时间：
2019-12-15 12:39:52
阅读次数：
136
0.官方网站 1.环境准备： 1.搭建单机版的ES环境 2.虚拟机上nc -l 9000方式产生数据 2.需求分析 通过socket的nc -l 9000方式产生数据，然后将数据存入到es中 3.代码实例 flink-sink-es-example ...
分类：
其他好文 时间：
2019-12-09 17:00:37
阅读次数：
576
1.环境准备： 1.搭建zookeeper和kafka 2.虚拟机上nc -l 9000方式产生数据 2.需求分析： 通过socket的nc -l 9000方式产生数据，然后将数据以字符串的形式存入到kafka中 3.代码实例 flink-kafka-example ...
分类：
其他好文 时间：
2019-11-26 17:49:18
阅读次数：
90
数据源Source RPC异构流数据交换 Avro Source Thrift Source 文件或目录变化监听 Exec Source Spooling Directory Source Taildir Source MQ或队列订阅数据持续监听 JMS Source SSL and JMS Sou ...
分类：
Web程序 时间：
2019-11-22 10:48:12
阅读次数：
84
