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,一经查实,立即删除!

相关文章

DIY_DE2开发板介绍

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

利用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中怎么去掉[]外的引号_如何正确检查发动机中的机油量?从机油尺处向外窜气是怎么回事?...

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

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

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

html爱心代码

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

分享制作精良的知识管理系统 配置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…

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

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

C++课堂整理--第一章内容

提前声明&#xff1a; 本文内容为华北水利水电大学研究生C课程&#xff0c;如有 侵权请告知&#xff0c;作者会予以删除 1.C特点 1.历史悠久。2.应用广泛。3.兼容c。4.面向对象。5.适合编写系统程序。6.有助于理解计算机的工作过程&#xff0c;深入理解计算机的原理和概念 …

oauth2 access_denied 不允许访问_OAuth 2 是什么-入门介绍

OAuth 2是什么OAuth 2是一个可以通过浏览器&#xff0c;手机等多种设备进行安全授权的一个标准简单的开源协议。随着互联网的兴起以及普及&#xff0c;越来越多的应用出现在用户的面前。这些应用大部分都是相对独立的以及由不同的公司进行运营的。不同的应用也保存了不同的数据…

基于TCP协议的网络程序(基础学习)

下图是基于TCP协议的客户端/服务器程序的一般流程&#xff1a; 图 37.2. TCP协议通讯流程 服务器调用socket()、bind()、listen()完成初始化后&#xff0c;调用accept()阻塞等待&#xff0c;处于监听端口的状态&#xff0c;客户端调用socket()初始化后&#xff0c;调用connect(…

一段代码认识C++中const不同位置的用处

#include<iostream> using namespace std ; int main () { const int A 78 ;const int B 25 ;int C 13 ;//---------const在数据类型前-------------------- const int *pi &A ;//*pi 56 ;// 错误, 不能修改所指常量。此时*pi指向的是常量A。 pi &…

wcf系列学习5天速成——第五天 服务托管

今天是系列的终结篇&#xff0c;当然要分享一下wcf的托管方面的知识。 wcf中托管服务一般有一下四种&#xff1a; Console寄宿&#xff1a; 利于开发调试&#xff0c;但不是生产环境中的最佳实践。 winform寄宿&#xff1a; 方便与用户进行交互&#x…

ASP.NET MVC Music Store教程(2):控制器

ASP.NET MVC Music Store教程&#xff08;2)&#xff1a;控制器 转自http://firechun.blog.163.com/blog/static/3180452220110272197830/在传统的Web架构中&#xff0c;URL总是映射到磁盘上的文件。例如&#xff1a;一个类似于“/Products.aspx”或“/Products.php”的URL可能…

C语言:利用泰勒级数计算sinx的值

题目&#xff1a; 代码&#xff1a; #include<stdio.h> #include<math.h> int main(){int sign1,n1;double x3,term,a,sinx0;//scanf("%lf",&x);termx;while(fabs(term)>0.00001){sinxsign*term;nn2;apow(x,n);double b1;for(int i1;i<n;i){…

C++课堂整理--第二章内容

提前声明&#xff1a; 本文内容为华北水利水电大学研究生C课程&#xff0c;如有 侵权请告知&#xff0c;作者会予以删除 1程序控制结构 语句是程序的基本语法成分。程序设计语言的语句按功能可以分成三类&#xff1a;声明语句 指示编译器分配内存&#xff0c;或者提供程序…

我的电脑 III

耳机用的是飞利浦的&#xff0c;和上学那时候的差不多 老的那个睡觉的时候压碎了&#xff0c;我胖了 然后去找音箱 网店&#xff0c;专卖店&#xff0c;电脑城&#xff0c;走了一遍又一遍 没个看的上的 一个月以后&#xff0c;终于决定买飞利浦那个了 白色的&#xff0c;和整个…

mybatis删除成功返回0_你还在用分页?试试 MyBatis 流式查询,真心强大!

转自&#xff1a;捏造的信仰segmentfault.com/a/1190000022478915基本概念流式查询指的是查询成功后不是返回一个集合而是返回一个迭代器&#xff0c;应用每次从迭代器取一条查询结果。流式查询的好处是能够降低内存使用。如果没有流式查询&#xff0c;我们想要从数据库取 1000…

C++程序设计--第三章内容

提前声明&#xff1a; 本文内容为华北水利水电大学研究生C课程&#xff0c;如有 侵权请告知&#xff0c;作者会予以删除 1.函数 函数作用 —— 任务划分&#xff1b;代码重用定义形式 类型 函数名 &#xff08; 形式参数表&#xff09;{语句序列}调用形式 函数名&#x…