Author:飘易 @ 2019/6/26 21:57:33
EMQX服务器搭建好之后,我们需要将MQTT消息持久化保存到mysql等数据库里了,这个时候就需要借助kafka这个消息中间件了,下面飘易来介绍下Kafka插件编译安装。
……Author:飘易 @ 2019/6/26 21:48:02
安装kafka的扩展之前,在安装php-rdkafka之前,需要先安装librdkafka,接下来就可以利用PHP编写消费者了,有2种消费者类型:High-level consumer、Low-level consumer,区别是kafka服务器不会记录低级别消费者,但不影响它们的消费。
……Author:飘易 @ 2019/6/26 21:33:46
kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。
……Author:飘易 @ 2019/6/26 21:14:01
本篇文章飘易使用储存库安装 EMQ X最新版,注意这种方式不推荐,因为不方便自定义插件的加载和开发,只能使用官方集成好的插件。但好处是可以快速安装,只需要几分钟就好了。如果你不需要自定义插件,就用这个方式安装吧。
……Author:飘易 @ 2019/6/26 17:43:23
本片文章介绍源码编译安装EMQX,后续需要搭配自定义插件将mqtt消息转发到Kafka消息中间件里。我们选择EMQX 开源版,如果要将消息持久化到Kafka里(收费的企业版里支持),需要自行编写插件,幸好Github有开源的kafka插件,我们找V3的一个稳定版本以便能适配kafka插件(目前还不适配3.1或更高版本),因此我们选择3.0.1版本
……Author:飘易 @ 2019/6/26 17:30:28
随着万物互联,物联网应用将是未来10年最火热的行业之一,飘易把搭建物联网平台过程中的一些知识点分享出来。EMQX服务器搭建、Kafka消息中间件、TCP服务器选型、云平台设计、设备端连接、APP控制
……Author:飘易 @ 2019/4/1 15:50:56
Supervisor是用Python开发的一个client/server服务,是Linux/Unix系统下的一个进程管理工具,不支持Windows系统。它可以很方便的监听、启动、停止、重启一个或多个进程。用Supervisor管理的进程,当一个进程意外被杀死,supervisort监听到进程死后,会自动将它重新拉起,很方便的做到进程自动恢复的功能,不再需要自己写shell脚本来控制。
……Author:飘易 @ 2019/2/12 20:49:20
本文记录下飘易在Python开发中遇到的一些常见问题
……Author:飘易 @ 2019/2/2 17:02:45
我们来看在C#中如何实现RSA加密解密。直接上代码,如下类是RSA算法实现的加密,加解密,签名以及签名的验证。
……Author:飘易 @ 2019/1/5 10:42:25
利用阿里云飞燕平台做智能家居app,先总体来说一下架构的事,飘易做的这款APP最终要控制的是家里的门窗,通过APP调用阿里云飞燕平台实现家里门窗的开、关、锁(支持百分比的开关),那这里就涉及到了硬件、平台、APP端。
……Author:飘易 @ 2018/6/5 10:16:29
在使用Elasticsearch的过程中,一般的分页需求我们可以使用form和size的方式实现,但是这种分页方式在深度分页的场景下应该是要避免使用的。从es 5.0版本开始,es提供了新的参数 search_after 来解决这个问题,search_after 提供了一个活的游标来拉取从上次返回的最后一个请求开始拉取下一页的数据。
……Author:飘易 @ 2018/5/31 12:47:28
Elasticsearch 是一个实时的分布式搜索与分析引擎,被广泛用来做全文搜索、结构化搜索、分析。在使用过程中,有一些典型的使用场景,比如分页、遍历等。在使用关系型数据库中,我们被告知要注意甚至被明确禁止使用深度分页
……Author:飘易 @ 2018/5/18 21:44:36
vim命令常用方法
……Author:飘易 @ 2018/4/28 15:03:12
原生PHP、Laravel、MIXPHP、Go高并发性能测试QPS;web架构为:把php请求利用Nginx反向代理给后端的Apache或者MIXPHP
……Author:飘易 @ 2018/4/28 14:22:36
Apache的ab命令模拟多线程并发请求,测试服务器负载压力,也可以测试nginx、lighthttp、IIS等其它Web服务器的压力。
……