yangl

Selector selector = Selector.open();
channel.configureBlocking(false);
SelectionKey key = channel.register(selector, SelectionKey.OP_READ);
while(true) {
  int readyChannels = selector.select();
  if(readyChannels == 0) continue;
  Set selectedKeys = selector.selectedKeys();
  Iterator keyIterator = selectedKeys.iterator();
  while(keyIterator.hasNext()) {
    SelectionKey key = keyIterator.next();

yangl

package com.jd.promotion.common;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.*;
import redis.clients.jedis.exceptions.JedisConnectionException;
import redis.clients.jedis.exceptions.JedisException;
 
import java.util.List;
import java.util.Map;

yangl

<!-- 1.将如下内容加入pom.xml -->


<javasimon.version>3.5.0</javasimon.version>
<sirona.version>0.2-incubating</sirona.version>


<!-- Monitor begin -->
<!-- javasimon -->
<!-- Core JAR is absolutely necessary to use Simons (Stopwatch, etc.) -->

yangl

<tr>
            <th>
                <span class="requiredField">*</span>开始时间:
            </th>
            <td>
                <input type="text" id="startTime" name="startTime" class="laydate-icon"
                       value="$!dateTool.format("yyyy-MM-dd HH:mm:ss",$!act.startTime)"
                       />
            </td>
        </tr>

yangl

package com.iuni.order.common.mapper;

import org.nustaq.serialization.FSTObjectInput;
import org.nustaq.serialization.FSTObjectOutput;

import java.io.*;


// 3.0可用下边这个简单的接口了，FST并不支持添加删除字段！
// FSTCoder fst = new DefaultCoder();

yangl

package com.iuni.ops.common;

import com.google.common.collect.Lists;
import com.google.common.io.Files;
import com.jcraft.jsch.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.Assert;
import org.springframework.util.DigestUtils;

yangl

<bean id="hikariDataSource" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close">

        <!-- 基本属性 url、user、password -->
        <property name="jdbcUrl" value="${bc0.jdbc.url}"/>
        <property name="username" value="${bc0.jdbc.username}"/>
        <property name="password" value="${bc0.jdbc.password}"/>

        <property name="dataSourceProperties">
            <props>
                <prop key="cachePrepStmts">true</prop>

yangl

默认使用jdk1.8编译运行的，如果要使用jdk1.7则在build.sbt中添加如下指定编译jdk版本：
javacOptions ++= Seq("-source", "1.7", "-target", "1.7")

sbt clean dist

https://github.com/yahoo/CMAK

解压kafka-manager-VERSION.zip，然后用下边启动脚本启动即可，不用再配置任何参数、hosts等

注意：由于编译时用的jdk1.7，所以运行时也要拿1.7来跑，在Add Cluster后zk上应该会新建有kafka-manager节点。

yangl

1.首先安装zookeeper机群： 修改其config目录下的zoo.cfg，主要修改dataDir、server.A=B:C:D参数即可； 然后在dataDir下创建myid文件，内容为当前节点的id；

      # The number of milliseconds of each tick
      tickTime=2000
      # The number of ticks that the initial
      # synchronization phase can take
      initLimit=10

yangl

OpenTSDB
安装

http://opentsdb.net/docs/build/html/installation.html

1.安装依赖：

Runtime Requirements

		A Linux system