ITPub博客

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...

 1.                消息中心（由Node.js+Socket.io实现）负责消息的推送。为了保证有良好的性能，部署了两台服务器。通过Nginx做负载均衡。2.             &...

 目前正在从事一个有关物业App的软件项目实施，利用此App物管人员可以接收到呼叫中心派出的工单（主要有维修，保洁，安全，投诉，送水，跑腿，代办等）。为了确保物管人员能及时响应业主的诉求，实时的消息提醒成为其中不可缺少的一部分。起初，采用了百度云推送，但实施的效果并没有想象中的那么好，特别...

forever可以看做是一个nodejs的守护进程，能够启动，停止，重启我们的app应用。用途forever的用途就是帮我们更好的管理我们node App服务，本质上就是在forever进程之下，创建一个node app的子进程。比如，你有一个基于express的或者其他的一些个应用那么，它将会很方便你更新和操作你的服务，并且保证你服务能...

ActiveMQ支持MQTT协议并且在JMS和MQTT客户端之间自动进行消息转换。为了是ActiveMQ支持ＭＱＴＴ协议，可以在activemq.xml配置文件中做以下配置：当一个客户端连接ＭＱＴＴ服务器的时候，会发送心跳信号来检测连接是否有效，通常心跳信号默认的时间间隔为１０秒钟。　ActiveMQ默认会将连接的有效期设置为 1.5*10=15秒但是，如果客户端设置keep-alive为0的时候，ActiveMQ会一直认为客户端连接有效，而不会自动关闭。这种情况会导致连接的泄露，因此在服务端也设置一个默认的有效连接时间是必要的。下面的参数则是在服务端设置一个连接有效时间：ActiveMQ9.0版本以后，提供了对WebSocket协议的支持

<!DOCTYPE html><html lang="en">  <head>    <meta charset="utf-8">    <title>Chat Example Using MQTT Over WebSockets</title>    <!--[if lt IE 9]>      <script src="http://html5shim.googlecode.com/svn/trunk/html5.js"></...

前言：fusesource版本：mqtt-client-1.7-uber.jar下载地址：https://github.com/fusesource/mqtt-clientfusesource提供三种mqtt client api: 阻塞API，基于Futur的API和回调API。其中，回调API是最复杂的也是性能最好的，另外两种均是对回调API的封装。 我们下面就简单介绍一下回调API的使用方法。import org.fus...