gearman安装

在 2015年6月3日2015年6月4日上张贴由 BestLove

//gearman是一个任务分发的程序框架，可以用来当队列用，可以替代多语言集成时常用的webservice方式，可以实现分布式负载均衡
//gearman请求处理流程：client (c|php|xxx) -> job (gearman服务器) -> worker (c|php|xxx)
//gearman是通过分发给不同服务器的多个work来实现负载均衡的

wget https://launchpadlibrarian.net/165674261/gearmand-1.1.12.tar.gz
tar -zxvf gearmand-1.1.12.tar.gz
mv gearmand-1.1.12 /usr/local/gearmand
cd /usr/local/gearmand
./configure
//如果报错 configure: error: could not find gperf
yum install gperf*
./configure
//如果报错 configure: error: Unable to find libuuid
yum install libuuid*
./configure
make
make install

//启动gearmand
mkdir -p /usr/local/var/log/
cd /usr/local/var/log/
touch gearmand.log
//如果是root用户 -u root 默认端口4730
gearmand -d -u root

//gearman是一个任务分发的程序框架，可以用来当队列用，可以替代多语言集成时常用的webservice方式，可以实现分布式负载均衡

//gearman请求处理流程：client (c|php|xxx) -> job (gearman服务器) -> worker (c|php|xxx)

//gearman是通过分发给不同服务器的多个work来实现负载均衡的

wget https://launchpadlibrarian.net/165674261/gearmand-1.1.12.tar.gz

tar -zxvf gearmand-1.1.12.tar.gz

mv gearmand-1.1.12 /usr/local/gearmand

cd /usr/local/gearmand

./configure

//如果报错 configure: error: could not find gperf

yum install gperf*

./configure

//如果报错 configure: error: Unable to find libuuid

yum install libuuid*

./configure

make

make install

//启动gearmand

mkdir -p /usr/local/var/log/

cd /usr/local/var/log/

touch gearmand.log

//如果是root用户 -u root 默认端口4730

gearmand -d -u root

wget http://pecl.php.net/get/gearman-1.1.2.tgz
tar -zxvf gearman-1.1.2.tgz 
cd gearman-1.1.2
phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make
make install
//设置php.ini extension=gearman.so 并重启nginx php-fpm

wget http://pecl.php.net/get/gearman-1.1.2.tgz

tar -zxvf gearman-1.1.2.tgz

cd gearman-1.1.2

phpize

./configure --with-php-config=/usr/local/php/bin/php-config

make

make install

//设置php.ini extension=gearman.so 并重启nginx php-fpm

<?php
$worker= new \GearmanWorker();
$worker->addServer('192.168.22.190', 4730);
$worker->addServer('192.168.22.191', 4730);
$worker->addFunction('test', 'doWorkTest');
while ($worker->work());
function doWorkTest($job) {
    return $job->workload();
}

<?php

$worker= new \GearmanWorker();

$worker->addServer('192.168.22.190', 4730);

$worker->addServer('192.168.22.191', 4730);

$worker->addFunction('test', 'doWorkTest');

while ($worker->work());

function doWorkTest($job) {

return $job->workload();

}

<?php
$client= new \GearmanClient();
$client->addServer('192.168.22.190', 4730);
$client->addServer('192.168.22.191', 4730);
echo $client->do('test', 'Hello World!'), "\n";

<?php

$client= new \GearmanClient();

$client->addServer('192.168.22.190', 4730);

$client->addServer('192.168.22.191', 4730);

echo $client->do('test', 'Hello World!'), "\n";

syslog日志

在 2015年6月3日2015年6月3日上张贴由 BestLove

<?php
//php可能默认禁用了openlog和syslog函数，在php.ini disable_function中去除
//第一个参数 标识符 可以理解为一个标题吧 string
//第二个参数 一些常量配置 具体参照php.net
//第三个参数 消息级别 LOG_USER表示通用的用户级的消息 具体参照php.net
//windows平台的话，只能使用LOG_USER这个消息级别
openlog('syslogtest', NULL, LOG_USER);
//LOG_INFO:普通信息 LOG_WARING:警告信息 LOG_ERR:错误信息 具体参照php.net
//第二个参数为日志内容 string
syslog(LOG_INFO, 'this is a test,level is info');
syslog(LOG_WARING, 'this is a test,level is waring');
syslog(LOG_ERR, 'this is a test,level is err');
//关闭系统日志链接
closelog();

<?php

//php可能默认禁用了openlog和syslog函数，在php.ini disable_function中去除

//第一个参数标识符可以理解为一个标题吧 string

//第二个参数一些常量配置具体参照php.net

//第三个参数消息级别 LOG_USER表示通用的用户级的消息具体参照php.net

//windows平台的话，只能使用LOG_USER这个消息级别

openlog('syslogtest', NULL, LOG_USER);

//LOG_INFO:普通信息 LOG_WARING:警告信息 LOG_ERR:错误信息具体参照php.net

//第二个参数为日志内容 string

syslog(LOG_INFO, 'this is a test,level is info');

syslog(LOG_WARING, 'this is a test,level is waring');

syslog(LOG_ERR, 'this is a test,level is err');

//关闭系统日志链接

closelog();

//windows 右键计算机->管理->系统工具->系统查看器->windows日志->应用程序 即可看到日志信息

//为了配合分布式环境，可使用单独的syslog中央日志服务器
//其他多台服务器在写syslog的时候，都会把日志记录的中央日志服务器
//vim /etc/rsyslog.conf
//service rsyslog restart start stop
//chkconfig rsyslog on能让rsyslog客户端在每次系统重启后自动启动

//客户端配置
//加载模块 imuxsock 必须   imklog immark 可选 
$ModLoad imuxsock           //提供本地系统日志支持（例如，通过logger命令） 
$ModLoad imklog             //核测井提供支持（先前所做的rklogd）
$ModLoad immark             //标记提供信息的能力
//.xxx:  表示大于等于xxx级别的信息
//.=xxx：表示等于xxx级别的信息
//.!xxx：表示在xxx之外的等级的信息
//@表示UDP 默认端口514 @@表示TCP 默认端口10514
user.=err              @@192.168.22.191
user.=warning          @@192.168.22.191
user.=info             @@192.168.22.191
//其他选项默认即可，或者全部关闭

//中央日志服务器配置
//允许514端口接收tcp协议传过来的消息
$ModLoad imtcp              //tcp协议
$InputTCPMaxSessions 500    //tcp接收连接数为500个
$InputTCPServerRun 514      //端口为514
$MaxMessageSize 32k         //最大日志大小32k
//定义日志文件地址 每月一个文件夹 每天一个文件
$template DynFile, "/var/log/user/%$year%%$month%/%$year%%$month%%$day%.log"
user.=err                   ?DynFile
user.=warning               ?DynFile
user.=info                  ?DynFile
//其他选项默认即可，或者全部关闭

//windows 右键计算机->管理->系统工具->系统查看器->windows日志->应用程序即可看到日志信息

//为了配合分布式环境，可使用单独的syslog中央日志服务器

//其他多台服务器在写syslog的时候，都会把日志记录的中央日志服务器

//vim /etc/rsyslog.conf

//service rsyslog restart start stop

//chkconfig rsyslog on能让rsyslog客户端在每次系统重启后自动启动

//客户端配置

//加载模块 imuxsock 必须 imklog immark 可选

$ModLoad imuxsock //提供本地系统日志支持（例如，通过logger命令）

$ModLoad imklog //核测井提供支持（先前所做的rklogd）

$ModLoad immark //标记提供信息的能力

//.xxx: 表示大于等于xxx级别的信息

//.=xxx：表示等于xxx级别的信息

//.!xxx：表示在xxx之外的等级的信息

//@表示UDP 默认端口514 @@表示TCP 默认端口10514

user.=err @@192.168.22.191

user.=warning @@192.168.22.191

user.=info @@192.168.22.191

//其他选项默认即可，或者全部关闭

//中央日志服务器配置

//允许514端口接收tcp协议传过来的消息

$ModLoad imtcp //tcp协议

$InputTCPMaxSessions 500 //tcp接收连接数为500个

$InputTCPServerRun 514 //端口为514

$MaxMessageSize 32k //最大日志大小32k

//定义日志文件地址每月一个文件夹每天一个文件

$template DynFile, "/var/log/user/%$year%%$month%/%$year%%$month%%$day%.log"

user.=err ?DynFile

user.=warning ?DynFile

user.=info ?DynFile

//其他选项默认即可，或者全部关闭

inotify文件监控

在 2015年6月2日上张贴由 BestLove

wget http://pecl.php.net/get/inotify-0.1.6.tgz
tar -zxvf ./inotify-0.1.6.tgz
cd inotify-0.1.6
phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make
make install
//在php.ini中加入extension=inotify.so
/etc/init.d/nginx restart
/etc/init.d/php-fpm restart

wget http://pecl.php.net/get/inotify-0.1.6.tgz

tar -zxvf ./inotify-0.1.6.tgz

cd inotify-0.1.6

phpize

./configure --with-php-config=/usr/local/php/bin/php-config

make

make install

//在php.ini中加入extension=inotify.so

/etc/init.d/nginx restart

/etc/init.d/php-fpm restart

<?php
$file = '/tmp/test.txt';
$fd = inotify_init();
//IN_MODIFY表示当文件内容被修改时候 具体参数可参靠php.net
$watch_descriptor = inotify_add_watch($fd, $file, IN_MODIFY);
if (!$watch_descriptor) {
    echo 'nothing to modify';exit;
}
$handle = fopen($file, 'r');
//把文件指针移动到文件底部，防止脚本中断后再次开启监听会读取整个文件
fseek($handle, 0, SEEK_END);
while(true){
    $event = inotify_read($fd);
    if ($event) {
        while ($line = stream_get_line($handle, 4096, "\n")) {
            //do someing... insert into database | push queue | data handle with storm
            echo $line . "\n";
        }
    }
}
inotify_rm_watch($fd, $watch_descriptor);
fclose($handle);
fclose($fd);

<?php

$file = '/tmp/test.txt';

$fd = inotify_init();

//IN_MODIFY表示当文件内容被修改时候具体参数可参靠php.net

$watch_descriptor = inotify_add_watch($fd, $file, IN_MODIFY);

if (!$watch_descriptor) {

echo 'nothing to modify';exit;

}

$handle = fopen($file, 'r');

//把文件指针移动到文件底部，防止脚本中断后再次开启监听会读取整个文件

fseek($handle, 0, SEEK_END);

while(true){

$event = inotify_read($fd);

if ($event) {

while ($line = stream_get_line($handle, 4096, "\n")) {

//do someing... insert into database | push queue | data handle with storm

echo $line . "\n";

}

inotify_rm_watch($fd, $watch_descriptor);

fclose($handle);

fclose($fd);

唐晓锋–BLOG

This is just a personal note.

月份：2015年6月

gearman安装

syslog日志

inotify文件监控