ITPub博客

重新configure 后，出现别的错误：fatal error: uuid/uuid.h: No such file or directory这是因为没有uuid库和头文件，需要安装e2fsprogs,试过yum命令安装，问题没解决，需要从源码编译wget http://downloads.sourceforge.net/e2fsprogs/e2fsprogs-1.41.14.tar.gztar xvzf e2fsprogs-1.41.14.tar.gz进入e...

mosquitto_sub 命令参数说明1. -c  设定‘clean session’为无效状态，这样一直保持订阅状态，即便是已经失去连接，如果再次连接仍旧能够接收的断开期间发送的消息。2. -d  打印debug信息3. -h  指定要连接的域名  默认为localhost4. -i 指定clientId5. -I 指定clientId前缀6. -k ke...

mosquitto 参数配置1.retry_interval 当QoS为1或2的消息已经被发送后，mosquitto在一段时间内仍未接收到客户端的反馈消息,将重新发送消息。 默认为20秒2.sys_interval 每隔一段时间将更新$SYS层级话题的状态，其中包含着proker的状态信息。 默认为10秒3.store_clean_interval表示间隔多长时间...

mosquitto命令参数说明1. -c  配置文件从文件中加载配置参数 如果没有指定默认路径为/etc/mosquitto/mosquitto.conf2. -d   表示以后台守护进程的形式启动3. -p   指定监听端口 默认为18834. -v  监控日志  类似于在配置文件中把log_type 设置为allmosquitto broker状态监控...

Mosquitto是一个开源(BSD许可证)的消息代理，实现MQTT(消息队列遥测传输)协议版本3.1。MQTT（MQ Telemetry Transport），消息队列遥测传输协议，轻量级的发布/订阅协议，适用于一些条件比较苛刻的环境，进行低带宽、不可靠或间歇性的通信。值得一提的是mqtt提供三种不同质量的消息服务：“至多一次”，消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。“至少一次”，确保消息到达，但消息重复可能会发生。“只有一次”，确保消息到达一次。这一级别可用于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果

                          消息游标如果消费者够快的话，消息会被及时消费，否则堵塞的消息会被存储（消息游标被pending）当队列中的消息被消费完时，阻塞的消息被重新消费。  消息游标共有三类：Store...

1）KahaDb和AMQ Message Store两种持久方式如何选择？官方：From 5.3 onwards - we recommend you use KahaDB - which offers improved scalability and recoverability over the AMQ Message Store.The AMQ Message Store which although faster than KahaDB - does not scales as well as KahaDB and rec...

背景：Flume是Cloudera提供的一个高可用的，高可靠的，分布式的海量日志采集、聚合和传输的系统，Flume支持在日志系统中定制各类数据发送方，用于收集数据；同时，Flume提供对数据进行简单处理，并写到各种数据接受方（可定制）的能力。flume版本：apache-flume-1.5.0.1-bin.tar.gz一：安装tar -zxvf apache-flume-...

一：redis 主从复制过程当配置好slave 后，slave 与master 建立连接，然后发送sync 命令。无论是第一次连接还是重新连接，master 都会启动一个后台进程，将数据库快照保存到文件中，同时master 主进程会开始收集新的写命令并缓存。后台进程完成写文件后，master 就发送文件给slave，slave将文件保存到硬盘上，再加载到内...

背景：Haproxy 版本：haproxy-1.4.24.tar.gzMysql 版本：5.5.31一：Haproxy安装tar -xzvf haproxy-1.4.24.tar.gzmake TARGET=linux26 PREFIX=/usr/local/haproxymake install PREFIX=/usr/local/haproxy二：Haproxy 配置1).首先创建组用户groubadd haproxyuseradd -g haproxy haproxyid haproxy 查看用户hapr...

背景:Coreseek版本：coreseek-4.1-beta.tar.gzMysql版本：  mysql-5.5.31.tar.gz 一：安装Tar –zxvf coreseek-4.1-beta.tar.gzCd coreseek-4.1-betacd mmseg-3.2.14./configure --prefix=/usr/local/mmsegMake Make install如果报错，执行下面的操作Aclocal...

1.卸载rhel的默认安装的yum包查看yum包：# rpm -qa|grep yum卸载yum包。卸载要使用nodeps参数，否则由于依赖关系是无法卸载成功的：# rpm -qa|grep yum|xargs rpm -e --nodeps2.下载新的yum包并安装(请注意下载对应系统及位数的安装包)1 # wget http://tel.mirrors.163.com/centos/5/os/x86_...

一：脚本文件#!/bin/shcp -rf /usr/local/apache-tomcat-7.0.11/logs/catalina.out   /usr/local/apache-tomcat-7.0.11/logs/catalina.out.$(date -d "yesterday" +"%Y%m%d").logecho >  /usr/local/apache-tomcat-7.0.11/logs/catalina.out二：添加定时任务crontab -u root -e01 00 * * * /bin/sh /...

node.js+socket.io消息中心源码

#user  nobody;worker_processes  1;#error_log  logs/error.log;#error_log  logs/error.log  notice;#error_log  logs/error.log  info;#pid        logs/nginx.pid;events {    worker_connections  10...

1. index.js  启动类var server = require("./server");var router = require("./router");var requestHandlers = require("./requestHandlers");var handle = {};handle["/"] = requestHandlers.start; handle["/start"] = requestHandlers.start; handle["/upload"] = requestHandlers.upload;hand...

Server.js  服务类1. 创建集群 cluster是一个nodejs内置的模块，用于nodejs多核处理。cluster模块，可以帮助我们简化多进程并行化程序的开发难度，轻松构建一个用于负载均衡的集群。var cluster = require('cluster');var http = require("http"); var url  = require("url");var logger = require(...

Http请求处理1.requestHandlers.js  http请求处理类var exec = require("child_process").exec;var querystring = require("querystring");var url = require("url");var fs = require("fs");var formidable = require("/usr/local/lib/node_modules/formidable");function start(response,request) { ...

 Redis.js    消息推送实施类 a)      generic-pool模块的安装 npm install generic-pool  -ggeneric-pool模块是nodejs的一个第三方模块，其作用为提供一个通用的连接池模块，可以通过generic-pool实现对redis连接池或者mysql数据库连接池等的管理.b) &...

 1.      代码目录结构 a)      logs日志文件目录b)      index.js启动文件c)      logger.js log4j日志类d)      md5.js md5加密类e) &nbsp...