forked from chenlinzhong/php-delayqueue
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathDqConf.php
More file actions
131 lines (109 loc) · 3.25 KB
/
DqConf.php
File metadata and controls
131 lines (109 loc) · 3.25 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
<?php
include_once 'DqLoader.php';
class DqConf{
/**
* 数据库配置
*/
static $db=array(
'host'=>'127.0.0.1',
'port'=>'3306',
'user'=>'user',
'password'=>'xx',
'database'=>'dq',
);
/**
* redis key前缀
*/
static $prefix='dq_';
static $bucket=2;
//监听端口
static $port=6879;
static $queue_len=5000;
static $socket_select_timeout=1;
/*消息的最大长度*/
static $msg_max_size=4096;
static $http_port=8088;
static $max_connection=2000;
static $redis_ping_interval=100;
static $flush_incr_interval=30; /*缓存计数时间*/
/**
* 日志路径
*/
static $logPath='/data1/www/logs/dq/';
/**
*进程名称不能包含空格
*/
const DQ_MASTER = 'dq-master';
const DQ_SERVER = 'dq-server';
const DQ_TIMER = 'dq-timer';
const DQ_CONSUME = 'dq-consume';
const DQ_REDIS_CHECKER = 'dq-redis-checker';
const DQ_HTTP_SERVER = 'dq-http-server';
/**
* 模块进程个数配置
*/
static $consume_nums=5;
static $notify_exp_nums=10;
static $config_refresh=300; //添加redis组，和topic之后，生效时长
/**
* php bin文件路径
*/
static $phpBin='/usr/local/bin/php';
/**
* 从数据库中读取redis的配置信息
*/
static $redis=array();
public static function getRedisServer(){
static $time=0;
if(empty($time) || time()-$time>self::$config_refresh || empty(self::$redis)) {
$arr = DqMysql::select('dq_redis');
$ret = array();
foreach ($arr as $v) {
$tmp = array();
$parts = explode(',', $v['t_content']);
list($host, $port, $auth) = self::parse_config($parts[0]);
$tmp['master'] = array('host' => $host, 'port' => $port, 'auth' => $auth,'id'=>$v['id']);
if (isset($parts[1])) {
list($host, $port, $auth) = self::parse_config($parts[1]);
$tmp['slave'] = array('host' => $host, 'port' => $port, 'auth' => $auth,'id'=>$v['id']);
}
$ret[] = $tmp;
}
$time = time();
self::$redis = $ret;
}
return self::$redis;
}
/**
* 解析redis配置
*/
public static function parse_config($part){
$segInfo = explode(':',$part);
return array(trim($segInfo[0]),trim($segInfo[1]),trim(isset($segInfo[2])?$segInfo[2]:''));
}
public static function getListenPort(){
return self::$port;
}
public static function getListenQueueLen(){
return self::$queue_len;
}
public static function getLogDir(){
return self::$logPath;
}
public static function getRedisMaster(){
return self::$redis['master'];
}
public static function getRedisSlave(){
return self::$redis['slave'];
}
//获取本机ip
public static function getLocalHost(){
return '0.0.0.0';
}
public static function get_socket_select_timeout(){
return self::$socket_select_timeout;
}
public static function get_msg_max_size(){
return self::$msg_max_size;
}
}