你驻足于春色中,于那独一无二的春色之中.
Hpfeeds和蜜罐是一对好搭档,想要完全掌握一个分布式蜜罐的信息传递,就来了解Hpfeeds协议吧!
feeds,供稿,原始数据。
hpfeeds是一个轻量级的验证发布-订阅协议(authenticated publish-subscribe protocol)。
轻量级好理解,就是代码量相对较少,功能相对不复杂。那什么是发布-订阅协议呢?订阅发布协议定义了一种一对多的依赖关系,让多个订阅者对象同时监听某一个主题对象。这个主题对象在自身状态变化时,会通知所有订阅者对象,使它们能够自动更新自己的状态。它是为了解决这样一种情况的发生,一个对象的改变需要同时改变其他对象,而且它不知道具体有多少对象需要改变。我的理解,这就类似于发传单,目标发送通知,没有指定特定的对象,通知会自动传播,观察者自己决定是否需要看传单,发送者对于传单是否被看一无所知。
详细的发布订阅者介绍可以戳这里:
https://msdn.microsoft.com/en-us/library/ff649664.aspx
线路协议组成如下:
首先是消息头:有两个参数,消息总长和消息类型
消息类型有以下几种:
error (0): errormessage
info (1): server name, nonce
auth (2): client id, sha1(nonce+authkey)
publish (3): client id, channelname, payload
subscribe (4): client id, channelname
数字代表消息类型,而冒号后面的内容则代表后续的消息字段
比如说当消息类型为3,publish时,后面的字段就会有四个:
client id的长度
client id
channelname的长度
channelname
payload
一个完整的消息如下:
length | opcode | next | identifier | next | channelname|payload
----------------------------------------------------------------
85 3 9 b4aa2@hp1 9 mwcapture 137941a3d8589f6728924c08561070bceb5d72b8,http://1.2.3.4/calc.exe
消息有了,整个消息的认证过程就是以下的几个步骤:
最终实现服务器、发布者、订阅者之间的解耦,彼此之间完全独立,互不干扰。
首先,正如以上所说的,整个协议实现了三方的功能独立。使用这种方式降低了应用与业务逻辑之间的耦合,统一一个对外的发布接口,只需要关心监听的类型,不关心监听的具体处理人。只管发,不管到不到。很方便的建立一种一对多的依赖关系。
在当一个对象的改变需要同时改变其他对象,而且它不知道具体有多少对象需要改变时,就可以使用订阅发布模式。
hpfeeds协议希望能够实现一个单一的连线形式,使得每一个人都可以在任何时间以任何语言去订阅发布数据,不同的数据以通道来划分,由通道的使用者来决定数据结构形式。而通道的验证通过authkey来完成,它由两部分组成,ident和secret,相当于身份和密码。密码在hash后和每一个临时连接标志一起发送给服务器,这样保证不会被窃听,所以它可以运行在SSL、TLS下。
优点
缺点
性能降低,订阅要进行管理
正常安装使用hpfeeds的步骤如下:
git clone https://github.com/rep/hpfeeds/
cd hpfeeds
python setup.py build
python setup.py install
安装成功后,会出现下面几个文件夹。
使用时先打开broker,运行其中的add_user.py添加用户信息:
根据提示信息,我们添加用户test,密码123456,拥有发布频道1,2,无订阅频道
再添加用户custom,密码123456,拥有订阅频道1,2,无发布频道
现在使用dump_users.py查看刚才创建的用户
如图所示,这里应经可以查看到刚才我们新建的用户了。
接下来,我们打开服务器feedbroker.py
再开启一个新的进程运行cli文件夹里的用户程序hpfeeds-client
先开启订阅者custom,使用1频道
此时,服务器端显示用户登录成功
我们再打开一个新的进程,以发布者test,使用1频道发布“helloworld”
我们可以看到发布者一旦发布完消息后,立即退出进程,并不确认消息是否收到
这时,服务器显示test登录成功
于此同时,订阅者custom成功接收到消息
到此,一次完整的发送、接收消息的流程就走完了。
通过这一过程,我们发现,频道与用户分离,发送和订阅者身份平等,只需订阅者实时监听,发送者可以即时发送即时撤出。
这里是对于hpfeeds协议的简单介绍,下一部分我会从代码的角度进一步分析该协议,并适当对于协议功能进行添加。
原创文章,转载请注明: 转载自零の杂货铺