Logstash是一个开源数据收集引擎，具有实时管道功能。Logstash可以动态地将来自不同数据源的数据统一起来，并将数据标准化到你所选择的目的地,logstash丰富的插件(logstash-input-jdbc,logstash-input-kafka,logstash-input-rabbi ...
分类：
其他好文 时间：
2019-11-24 14:09:54
阅读次数：
225
近来有个需求：想实现一个可以主动触发消息推送的功能，这个可以实现向模板消息那个，给予所有成员发送自定义消息，而不需要通过客户端发送消息，服务端上message中监听传送的消息进行做相对于的业务逻辑。 主动消息推送实现平常我们采用 swoole 来写 WebSocket 服务可能最多的用到的是open ...
分类：
Web程序 时间：
2019-11-23 14:30:45
阅读次数：
87
Kafka的结构与RabbitMQ类似，消息生产者向Kafka服务器发送消息，Kafka接收消息后，再投递给消费者。
生产者的消费会被发送到Topic中，Topic中保存着各类数据，每一条数据都使用键、值进行保存。
每一个Topic中都包含一个或多个物理分区（Partition），分区维护着消息... ...
分类：
编程语言 时间：
2019-11-22 23:28:34
阅读次数：
128
kafka 由于它自身的高性能发送与消费能力，而受到广大企业的喜欢，所以我们就先看看kafka 一些源码实现如下： 这段代码摘抄的是，kafka源码 生产者发送消息demo（kafka.examples.Producer） 里面的一个片段，主要是涉及到两个知识点，一个是异步发送消息， 回调函数的实现 ...
分类：
其他好文 时间：
2019-11-22 23:24:35
阅读次数：
79
1、Flume简介 ? (1) Flume提供一个分布式的，可靠的，对大数据量的日志进行高效收集、聚集、移动的服务，Flume只能在Unix环境下运行。 ? (2) Flume基于流式架构，容错性强，也很灵活简单。 ? (3) Flume、Kafka用来实时进行数据收集，Spark、Flink用来实 ...
分类：
Web程序 时间：
2019-11-22 12:11:59
阅读次数：
201
RabbitTemplate是我们在与SpringAMQP整合的时候进行发送消息的关键类该类提供了丰富的发送消息的方法，包括可靠性消息投递、回调监听消息接口ConfirmCallback、返回值确认接口ReturnCallback等等同样我们需要注入到Spring容器中，然后直接使用。在与sprin ...
分类：
其他好文 时间：
2019-11-21 16:42:06
阅读次数：
97
https://www.iteye.com/blog/tuposky-2017429 前面两章已经介绍了如何接入微信公众平台，这一章说说消息的接收和发送 可以先了解公众平台的消息api接口（接收消息，发送消息） http://mp.weixin.qq.com/wiki/index.php 接收消息 ...
分类：
微信 时间：
2019-11-21 13:57:10
阅读次数：
119
Rabbit MQ 的初步使用 一、先来说说 Java 代码中的初步集成吧 0. 业务场景模拟 1. 在默认的虚拟主机（virtual host） 下，创建一个名为 的`Topic`类型的交换机（exchange），并设置其属性为不持久化（durable）、不自动删除（autoDelete）。 2. ...
分类：
其他好文 时间：
2019-11-20 21:41:52
阅读次数：
74
1.spring整合rabbitMQ配置文件 rabbitmq-context.xml <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-ins ...
分类：
编程语言 时间：
2019-11-20 12:44:02
阅读次数：
64
来源：https://blog.csdn.net/kongxingxing/article/details/81119831 1.引入unity的 classes.jar包本人安装unity-5.6.1版本，目录为D:\Program Files\unity-561\Unity\Editor\Dat ...
分类：
移动开发 时间：
2019-11-19 17:17:02
阅读次数：
104
