Scribe应用实例

源代码里所给的example很简单,但大体上了模拟了其运行的过程,分三个部分。可参考里面的README文件:Configurarion(配置)、Running Scribe Server(运行服务器)、Logging messages(记录日志)

先运行Scribe example来看看效果。

1.Example1:向已经启动的Server发送消息,验证是否被记录下来。 #创建日志信息存放目录:

$mkdir /tmp/scribetest

#用example1.conf配置文件启动Scribe服务:

$scribed examples/example1.conf

#开启另一个终端,使用scribe_cat 向scribe服务发送信息:

$echo "hello world" | ./scribe_cat test

这时你很可能会出现如下错误提示:

也就是说python导入模块scribe失败,但我们打开/usr/lib/python2.6/site-packages,发现里面是有scribe的模块的,所以很可能是PYTHONPATH没有配置正确。使用如下命令进行配置: 进入到/etc目录,然后输入命令gedit profile(profile文件为系统的每个用户设置环境信息,当用户第一次登录时,该文件被执行),在此文件中添加如下内容:

$export  PYTHONPATH= ”/usr/lib/python2.6/site-packages”
$source /etc/profile

或 找到系统安装Python的路径(如我的是/usr/local/python2.6),将/usr/lib/python2.6/site-packages下内容拷贝到/usr/local/lib/python2.6/site-packages下即可。 #Verify that the message got logged:

$cat /tmp/scribetest/test/test_current
#检查scribe状态(requires root):
$./scribe_ctrl status
#检查scribe连接数 (you should see 1 message 'received good'):
$./scribe_ctrl counters
#关闭scribe服务:
$./scribe_ctrl stop
 

2) Example2:启动中心服务器和客户端服务器,然后开启一个终端并输入三条命令,并查看结果: 示意图如下 

执行如下命令:

#启动中央服务器
$scribed example2central.conf &
#启动客户端服务器
$scribed example2client.conf &
$mkdir /tmp/scribetest2
$scribed examples/example2central.conf
$scribed examples/example2client.conf
$echo "test message" | ./scribe_cat -h localhost:1464 test2
$echo "this message will be ignored" | ./scribe_cat -h localhost:1464 ignore_me
$echo "123:this message will be bucketed" | ./scribe_cat -h localhost:1464 bucket_me

查看结果:

$cat /tmp/scribetest/test2/test2_current
$cat /tmp/scribetest/bucket*/bucket_me_current
./scribe_ctrl status 1463
./scribe_ctrl status 1464
./scribe_ctrl counters 1463 #查看中心服务器的统计数据
./scribe_ctrl counters 1464 #查看客户端服务器的统计数据

当客户端服务器讲收到的信息发送给中心服务器后,会删除本地的存储。 结果显示:客户端收到三条消息,发送了三条消息;服务器端收到三条消息,忽略了一条消息。


3) Example3:如同Example2启动中心服务器和客户端服务器,但本例测试的是在中心服务器突然down掉的情况下,客户端服务器的缓冲存储功能。

$echo  "test message 1" | ./scribe_cat -h localhost:1464 test3   #发送消息1
$cat /tmp/scribetest/test3/test3_current #结果:test message 1
$./scribe_ctrl stop 1463 #down掉中心服务器
$./scribe_ctrl status 1463 #结果:Failed to get status
$echo "test message 2" | ./scribe_cat -h localhost:1464 test3 #发送消息2
$./scribe_ctrl status 1464 #结果:WARNING - Failed to connect
$echo "test message 3" | ./scribe_cat -h localhost:1464 test3 #发送消息3
$scribed examples/example2central.conf #重新启动中心服务器
$./scribe_ctrl status 1463 #结果:ALIVE
$./scribe_ctrl status 1464 #结果:ALIVE
$cat /tmp/scribetest/test3/test3_current

#结果:

test message 1
test message 2
test message 3

全部正常接收

转载于:https://www.cnblogs.com/oubo/archive/2011/10/28/2394610.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/434811.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

群晖docker签到京豆_利用Synology(群晖)Docker安装签到框架

利用Synology(群晖)Docker安装签到框架Mark • 2018 年 05 月 15 日1、前言之前一直想自己开一套WEB签到工具用,一方面是精力有限(老了),另一方面技术能力欠佳一直没有搞。去年时候在偶然机会下在V2ex了解到Binux大佬开发的一套签到框架系统qiandao&…

socket 编程入门教程(一)TCP server 端:6、创建“通讯 ”嵌套字

这里的“通讯”加上了引号,是因为实际上所有的socket都有通讯的功能,只是在我们的例子中,之前那个socket只负责listen,而这个socket负责接受信息并echo回去。我们现看看这个函数:boolTcpServer::isAccept() { unsi…

python离线安装pip出现timeout_Python pip安装包出现timeout的解决办法,修改国内的镜像源...

今天安装django时老是出现timeoutWARNING: Retrying (Retry(total4, connectNone, readNone, redirectNone, statusNone)) after connection broken by ConnectTimeoutError(at 0x00000000044BC9B0>, Connection to pypi.org timed out. (connect timeout15)): /simple/dian…

DIY_DE2开发板介绍

Altera官方有一个DE2开发板,该开发板的资源很丰富,外设也很齐全,采用的是十层电路板设计,价格自然很高了。本人仿照其原理图自制了一块,叫做DIY_DE2开发板。开发板采用核心板和底板的模式,方便使用&#xf…

socket 编程入门教程(一)TCP server 端:7、接收与发送

现在,我们通过accept()创建了新的socket,也就是我们类中的数据成员communicationSock,现在,我们就可以通过这个socket进行通讯了。TCP通讯模型在介绍函数之前,我们应该了解一些事实。TCP的Server/Client模型类似这样&a…

利用ROC找阈值点cutpoint

def Find_Optimal_Cutoff(TPR, FPR, threshold):y TPR - FPRYouden_index np.argmax(y)#阈值optimal_threshold threshold[Youden_index]#阈值对应的点point [FPR[Youden_index], TPR[Youden_index]]return optimal_threshold, pointtest_fpr, test_tpr, test_thresholds …

json中怎么去掉[]外的引号_如何正确检查发动机中的机油量?从机油尺处向外窜气是怎么回事?...

机油是发动机的血液,发动机中必须有足够多的机油,才能完成润滑、冷却等任务。为了让驾驶员随时能够查看到发动机中机油的存量,在发动机上都设置了一个机油尺,我们只要把它拔出来,就可以查看机油的液位了;而…

flex常见问题归纳

flex警告:swc“D:\Adobe\Adobe Flash Builder 4.5\sdks\4.5.1\frameworks\libs\framework.swc”具有默认样式并且在 library-path 中,表示依赖项将不带有样式进行链接。这可能会导致使用输出 swc 的应用程序出现外观丢失的现象。swc 应该放置在 external…

arcgis符号系统的分类方法介绍

使用标准分类方案 类范围和间隔的定义方式可确定属于各个类的数据的量以及地图的外观。分类方案包括两个主要部分:组织数据所参照的类数目以及指定类时所依据的方法。类数目取决于您的分析目的。然而,需要对为类分配数据时所依据的规则进行简要说明。对…

k8s往secret里导入证书_k8s中secret解析

概览Secret是用来保存小片敏感数据的k8s资源,例如密码,token,或者秘钥。这类数据当然也可以存放在Pod或者镜像中,但是放在Secret中是为了更方便的控制如何使用数据,并减少暴露的风险。用户可以创建自己的secret&#x…

HDU1856_More is better

题目大意: 让你输入n,然后输入n组数据,表示a与b的关系,最后求出关系最多一组的个数。注意(a与b有关系,b与c有关系,那么a与c就有关系) 解题思路: 并查集,…

html爱心代码

此处填写你爱人的名字 代码 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>Title</title> </head> <body> <!doctype html> <html> <head><meta charset&qu…

Linux TCP server系列(4)-浅谈listen与大并发TCP连接

背景&#xff1a; 服务器在调用listen和accept后&#xff0c;就会阻塞在accept函数上&#xff0c;accpet函数返回后循环调用accept函数等待客户的TCP连接。如果这时候又大量的用户并发发起connect连接&#xff0c;那么在listen有队列上限(最大可接受TCP的连接数)的情况下&#…

领航机器人广告段子_医院机器人物流广告词_段子网收录最新段子

瑞典RJO医疗供应商&#xff0c;机器人自助式物流领航者&#xff0c;拥有自己的机器人工作组&#xff0c;让医院处处散发出高科技。使用机器人物流体系&#xff0c;医院内部运输物料在标准化、可控、准时、高效方面有质的改变&#xff0c;大大提高医院对外形象。特征集广告词&am…

分享制作精良的知识管理系统 配置SQL Server文档数据库 完美实现博客文章的的下载,存储和浏览...

前一篇文章《分享制作精良的知识管理系统 博客备份程序 Site Rebuild》已经提到如何使用Site Rebuild来下载您所喜欢的博客文章&#xff0c;但是还不能实现把下载的文件导入进数据库中&#xff0c;无法实现在线浏览服务器中的文档数据。这一篇文章则帮助您建立文档数据库&#…

python绘制敏感性和特异性曲线(交叉)

示例 代码如下 test_fpr, test_tpr, test_thresholds roc_curve(y_test_two, dataset_blend_test_pred, pos_label1) test_roc_auc auc(test_fpr, test_tpr) plt.plot(test_thresholds, 1-test_fpr, labelspecificity) plt.plot(test_thresholds, test_tpr, labelsensitivit…

python迭代器创建序列_Python 中迭代器与生成器实例详解

Python 中迭代器与生成器实例详解本文通过针对不同应用场景及其解决方案的方式&#xff0c;总结了Python中迭代器与生成器的一些相关知识&#xff0c;具体如下&#xff1a;1.手动遍历迭代器应用场景&#xff1a;想遍历一个可迭代对象中的所有元素&#xff0c;但是不想用for循环…

一个网络资深者发起的思考

陈硕 (giantchen AT gmail) blog.csdn.net/Solstice 前几天我在新浪微博上出了两道有关 TCP 的思考题&#xff0c;引发了一场讨论 http://weibo.com/1701018393/eCuxDrta0Nn 。 第一道初级题目是&#xff1a; 有一台机器&#xff0c;它有一个 IP&#xff0c;上面运行了一个 TCP…

The Ransom of Red Chief

We can kidnap someone here. Who? Theres nobody rich in this town. The richest man in town, of course. Kidnap      绑架 rich         富 trouble      麻烦 Im not having a nice day. How much money have we got? Only two hundred dollars. Ra…