240 发简信
IP属地:陕西
  • 解决kafka consumer 无法从最新一条开始消费的问题

    首先贴代码: 这里已经设置了OffsetNewest,但是并没有从最新的一条开始消费。 然后在github上的issue上找到了答案: 因为在同...

  • Resize,w 360,h 240
    goroutine连接redis的坑

    今天使用redis读取数据,发现效率比较低,于是就使用了goroutine,但是发生了以下错误: 先贴一下代码:从redis中取数据: 主程序:...

  • mosquitto(3):关于发布和订阅的安全问题

    关于用户配置: mosquitto可以添加多个用户,只有使用用户名和密码才能进行发布和订阅。这是加强安全性性的一种方式。 首先打开mosquit...

  • Resize,w 360,h 240
    mosquitto(2):mosquitto桥接

    我之前看过一个博客上面说的是怎么去搭建mosquitto集群(http://www.cnblogs.com/yinyi521/p/6084029...

  • mosquitto(1):CentOS下安装mosquitto1.4.5

    1.安装工具 2.开始安装 下载压缩包并解压: 进入目录并安装: 这样就算安装完成了,但是我安装完成之后,发现和网上的教程有点不一样,就是我的配...

  • Resize,w 360,h 240
    对比一些MQTT的代理(broker)

    broker的主要职责是接受发布者发布的所有消息,并将其过滤后分发给不同的消息订阅者。如今有很多的broker,下面就是一张关于各种broker...

  • Resize,w 360,h 240
    对MQTT的一些笔记整理

    这里只是做了一些简单的笔记,这些内容都是通过看一个大神的文章和MQTT协议中文版文档总结的一些笔记: 1.MQTT协议的实现方式: 2.对传输消...