() {
+
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.getSet(key, value);
+ }
+ });
+ }
+
+ /**
+ * Increment the number stored at key by one. If the key does not exist or
+ * contains a value of a wrong type, set the key to the value of "0" before
+ * to perform the increment operation.
+ *
+ * INCR commands are limited to 64 bit signed integers.
+ *
+ * Note: this is actually a string operation, that is, in Redis there are
+ * not "integer" types. Simply the string stored at the key is parsed as a
+ * base 10 64 bit signed integer, incremented, and then converted back as a
+ * string.
+ *
+ * @return Integer reply, this commands will reply with the new value of key
+ * after the increment.
+ */
+ public Long incr(final String key) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.incr(key);
+ }
+ });
+ }
+
+ public Long incrBy(final String key, final long increment) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.incrBy(key, increment);
+ }
+ });
+ }
+
+ public Double incrByFloat(final String key, final double increment) {
+ return execute(new JedisAction() {
+ @Override
+ public Double action(Jedis jedis) {
+ return jedis.incrByFloat(key, increment);
+ }
+ });
+ }
+
+ /**
+ * Decrement the number stored at key by one. If the key does not exist or
+ * contains a value of a wrong type, set the key to the value of "0" before
+ * to perform the decrement operation.
+ */
+ public Long decr(final String key) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.decr(key);
+ }
+ });
+ }
+
+ public Long decrBy(final String key, final long decrement) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.decrBy(key, decrement);
+ }
+ });
+ }
+
+ // / Hash Actions ///
+ /**
+ * If key holds a hash, retrieve the value associated to the specified
+ * field.
+ *
+ * If the field is not found or the key does not exist, a special 'nil'
+ * value is returned.
+ */
+ public String hget(final String key, final String fieldName) {
+ return execute(new JedisAction() {
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.hget(key, fieldName);
+ }
+ });
+ }
+
+ public List hmget(final String key, final String... fieldsNames) {
+ return execute(new JedisAction>() {
+ @Override
+ public List action(Jedis jedis) {
+ return jedis.hmget(key, fieldsNames);
+ }
+ });
+ }
+
+ public Map hgetAll(final String key) {
+ return execute(new JedisAction>() {
+ @Override
+ public Map action(Jedis jedis) {
+ return jedis.hgetAll(key);
+ }
+ });
+ }
+
+ public void hset(final String key, final String fieldName,
+ final String value) {
+ execute(new JedisActionNoResult() {
+
+ @Override
+ public void action(Jedis jedis) {
+ jedis.hset(key, fieldName, value);
+ }
+ });
+ }
+
+ public void hmset(final String key, final Map map) {
+ execute(new JedisActionNoResult() {
+
+ @Override
+ public void action(Jedis jedis) {
+ jedis.hmset(key, map);
+ }
+ });
+
+ }
+
+ public Boolean hsetnx(final String key, final String fieldName,
+ final String value) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Boolean action(Jedis jedis) {
+ return jedis.hsetnx(key, fieldName, value) == 1 ? true : false;
+ }
+ });
+ }
+
+ public Long hincrBy(final String key, final String fieldName,
+ final long increment) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.hincrBy(key, fieldName, increment);
+ }
+ });
+ }
+
+ public Double hincrByFloat(final String key, final String fieldName,
+ final double increment) {
+ return execute(new JedisAction() {
+ @Override
+ public Double action(Jedis jedis) {
+ return jedis.hincrByFloat(key, fieldName, increment);
+ }
+ });
+ }
+
+ public Long hdel(final String key, final String... fieldsNames) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.hdel(key, fieldsNames);
+ }
+ });
+ }
+
+ public Boolean hexists(final String key, final String fieldName) {
+ return execute(new JedisAction() {
+ @Override
+ public Boolean action(Jedis jedis) {
+ return jedis.hexists(key, fieldName);
+ }
+ });
+ }
+
+ public Set hkeys(final String key) {
+ return execute(new JedisAction>() {
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.hkeys(key);
+ }
+ });
+ }
+
+ public Long hlen(final String key) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.hlen(key);
+ }
+ });
+ }
+
+ // / List Actions ///
+
+ public Long lpush(final String key, final String... values) {
+ return execute(new JedisAction() {
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.lpush(key, values);
+ }
+ });
+ }
+
+ public String rpop(final String key) {
+ return execute(new JedisAction() {
+
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.rpop(key);
+ }
+ });
+ }
+
+ public String brpop(final String key) {
+ return execute(new JedisAction() {
+
+ @Override
+ public String action(Jedis jedis) {
+ List nameValuePair = jedis.brpop(key);
+ if (nameValuePair != null) {
+ return nameValuePair.get(1);
+ } else {
+ return null;
+ }
+ }
+ });
+ }
+
+ public String brpop(final int timeout, final String key) {
+ return execute(new JedisAction() {
+
+ @Override
+ public String action(Jedis jedis) {
+ List nameValuePair = jedis.brpop(timeout, key);
+ if (nameValuePair != null) {
+ return nameValuePair.get(1);
+ } else {
+ return null;
+ }
+ }
+ });
+ }
+
+ /**
+ * Not support for sharding.
+ */
+ public String rpoplpush(final String sourceKey, final String destinationKey) {
+ return execute(new JedisAction() {
+
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.rpoplpush(sourceKey, destinationKey);
+ }
+ });
+ }
+
+ /**
+ * Not support for sharding.
+ */
+ public String brpoplpush(final String source, final String destination,
+ final int timeout) {
+ return execute(new JedisAction() {
+
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.brpoplpush(source, destination, timeout);
+ }
+ });
+ }
+
+ public Long llen(final String key) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.llen(key);
+ }
+ });
+ }
+
+ public String lindex(final String key, final long index) {
+ return execute(new JedisAction() {
+
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.lindex(key, index);
+ }
+ });
+ }
+
+ public List lrange(final String key, final int start, final int end) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public List action(Jedis jedis) {
+ return jedis.lrange(key, start, end);
+ }
+ });
+ }
+
+ public void ltrim(final String key, final int start, final int end) {
+ execute(new JedisActionNoResult() {
+ @Override
+ public void action(Jedis jedis) {
+ jedis.ltrim(key, start, end);
+ }
+ });
+ }
+
+ public void ltrimFromLeft(final String key, final int size) {
+ execute(new JedisActionNoResult() {
+ @Override
+ public void action(Jedis jedis) {
+ jedis.ltrim(key, 0, size - 1);
+ }
+ });
+ }
+
+ public Boolean lremFirst(final String key, final String value) {
+ return execute(new JedisAction() {
+ @Override
+ public Boolean action(Jedis jedis) {
+ Long count = jedis.lrem(key, 1, value);
+ return (count == 1);
+ }
+ });
+ }
+
+ public Boolean lremAll(final String key, final String value) {
+ return execute(new JedisAction() {
+ @Override
+ public Boolean action(Jedis jedis) {
+ Long count = jedis.lrem(key, 0, value);
+ return (count > 0);
+ }
+ });
+ }
+
+ // / Set Actions ///
+ public Boolean sadd(final String key, final String member) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Boolean action(Jedis jedis) {
+ return jedis.sadd(key, member) == 1 ? true : false;
+ }
+ });
+ }
+
+ public Set smembers(final String key) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.smembers(key);
+ }
+ });
+ }
+
+ // / Ordered Set Actions ///
+ /**
+ * return true for add new element, false for only update the score.
+ */
+ public Boolean zadd(final String key, final double score,
+ final String member) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Boolean action(Jedis jedis) {
+ return jedis.zadd(key, score, member) == 1 ? true : false;
+ }
+ });
+ }
+
+ public Double zscore(final String key, final String member) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Double action(Jedis jedis) {
+ return jedis.zscore(key, member);
+ }
+ });
+ }
+
+ public Long zrank(final String key, final String member) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.zrank(key, member);
+ }
+ });
+ }
+
+ public Long zrevrank(final String key, final String member) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.zrevrank(key, member);
+ }
+ });
+ }
+
+ public Long zcount(final String key, final double min, final double max) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.zcount(key, min, max);
+ }
+ });
+ }
+
+ public Set zrange(final String key, final int start, final int end) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrange(key, start, end);
+ }
+ });
+ }
+
+ public Set zrangeWithScores(final String key, final int start,
+ final int end) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrangeWithScores(key, start, end);
+ }
+ });
+ }
+
+ public Set zrevrange(final String key, final int start,
+ final int end) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrevrange(key, start, end);
+ }
+ });
+ }
+
+ public Set zrevrangeWithScores(final String key, final int start,
+ final int end) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrevrangeWithScores(key, start, end);
+ }
+ });
+ }
+
+ public Set zrangeByScore(final String key, final double min,
+ final double max) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrangeByScore(key, min, max);
+ }
+ });
+ }
+
+ public Set zrangeByScoreWithScores(final String key,
+ final double min, final double max) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrangeByScoreWithScores(key, min, max);
+ }
+ });
+ }
+
+ public Set zrevrangeByScore(final String key, final double max,
+ final double min) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrevrangeByScore(key, max, min);
+ }
+ });
+ }
+
+ public Set zrevrangeByScoreWithScores(final String key,
+ final double max, final double min) {
+ return execute(new JedisAction>() {
+
+ @Override
+ public Set action(Jedis jedis) {
+ return jedis.zrevrangeByScoreWithScores(key, max, min);
+ }
+ });
+ }
+
+ public Boolean zrem(final String key, final String member) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Boolean action(Jedis jedis) {
+ return jedis.zrem(key, member) == 1 ? true : false;
+ }
+ });
+ }
+
+ public Long zremByScore(final String key, final double start,
+ final double end) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.zremrangeByScore(key, start, end);
+ }
+ });
+ }
+
+ public Long zremByRank(final String key, final long start, final long end) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.zremrangeByRank(key, start, end);
+ }
+ });
+ }
+
+ public Long zcard(final String key) {
+ return execute(new JedisAction() {
+
+ @Override
+ public Long action(Jedis jedis) {
+ return jedis.zcard(key);
+ }
+ });
+ }
+}
diff --git a/src/main/java/cn/flaty/NettyPush/nosql/JedisUtils.java b/src/main/java/cn/flaty/NettyPush/nosql/JedisUtils.java
new file mode 100644
index 0000000..f02b564
--- /dev/null
+++ b/src/main/java/cn/flaty/NettyPush/nosql/JedisUtils.java
@@ -0,0 +1,39 @@
+package cn.flaty.NettyPush.nosql;
+
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.exceptions.JedisException;
+import cn.flaty.NettyPush.nosql.JedisTemplate.JedisAction;
+
+public class JedisUtils {
+
+ private static final String OK_CODE = "OK";
+ private static final String OK_MULTI_CODE = "+OK";
+
+ /**
+ * 判断 返回值是否ok.
+ */
+ public static boolean isStatusOk(String status) {
+ return (status != null)
+ && (OK_CODE.equals(status) || OK_MULTI_CODE.equals(status));
+ }
+
+ /**
+ * Ping the jedis instance, return true is the result is PONG.
+ */
+ public static boolean ping(JedisPool pool) {
+ JedisTemplate template = new JedisTemplate(pool);
+ try {
+ String result = template.execute(new JedisAction() {
+ @Override
+ public String action(Jedis jedis) {
+ return jedis.ping();
+ }
+ });
+ return (result != null) && result.equals("PONG");
+ } catch (JedisException e) {
+ return false;
+ }
+ }
+
+}
diff --git a/src/main/java/cn/flaty/NettyPush/nosql/RedisClientRepository.java b/src/main/java/cn/flaty/NettyPush/nosql/RedisClientRepository.java
new file mode 100644
index 0000000..97547a3
--- /dev/null
+++ b/src/main/java/cn/flaty/NettyPush/nosql/RedisClientRepository.java
@@ -0,0 +1,67 @@
+package cn.flaty.NettyPush.nosql;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+import cn.flaty.NettyPush.entity.packet.ClientPacket;
+
+/**
+ *
+ *
+ * did -> 设备ID
+ * appkey -> app唯一标识码
+ * appClientUId = md5(appKey+did)
+ *
+ * client:[id] -> [appClientUId] **[String]** **expire[x second]**
+ * [appkey] -> id **[set]**
+ * [appkey]:[os] -> id **[set]**
+ * [appkey]:[appVer] -> id **[set]**
+ * [appkey]:[label] -> id **[set]**
+ *
+ *
+ *
+ * @author flatychen
+ *
+ */
+@Repository
+public class RedisClientRepository {
+
+ private static int clientExpireTime = 30;
+ private static String clientsKeyPrefix = "clients:";
+ private static String clientKeyPrefix = "client:";
+
+// @Autowired
+ private JedisTemplate jedisTemplate;
+
+ private static Logger logger = LoggerFactory
+ .getLogger(RedisClientRepository.class);
+
+ /**
+ *
+ *
+ * @param client
+ * @return
+ * @author flatychen
+ */
+ public void saveClient(ClientPacket client) {
+ jedisTemplate.hset(clientsKeyPrefix + client.getAppKey(),
+ client.getRedisField(), client.getAppClientUID());
+ jedisTemplate.setex(clientKeyPrefix + client.getAppClientUID(), "1",
+ clientExpireTime);
+ }
+
+ /**
+ *
+ *
+ * @param client
+ * @return
+ * @author flatychen
+ */
+ public void touchClient(ClientPacket client) {
+ jedisTemplate.setex(clientKeyPrefix + client.getAppClientUID(), "1",
+ clientExpireTime);
+ }
+
+}
diff --git a/src/main/java/cn/flaty/NettyPush/repository/ClientRepository.java b/src/main/java/cn/flaty/NettyPush/repository/ClientRepository.java
new file mode 100644
index 0000000..7fa5a8f
--- /dev/null
+++ b/src/main/java/cn/flaty/NettyPush/repository/ClientRepository.java
@@ -0,0 +1,25 @@
+package cn.flaty.NettyPush.repository;
+
+import java.util.List;
+
+import org.apache.commons.lang.time.DateUtils;
+
+import cn.flaty.NettyPush.entity.packet.ClientPacket;
+import cn.flaty.NettyPush.entity.persitence.Client;
+
+public interface ClientRepository {
+
+ @SuppressWarnings("deprecation")
+ public static long client_db_live_time = DateUtils.MILLIS_IN_SECOND * 40;
+
+ public boolean insertClient(ClientPacket c);
+
+ public Client getClient(String did);
+
+ public List queryClients(String appKey);
+
+ public boolean touchClient(ClientPacket c);
+
+ public boolean delExpireClient();
+
+}
diff --git a/src/main/java/cn/flaty/NettyPush/repository/H2ClientRepository.java b/src/main/java/cn/flaty/NettyPush/repository/H2ClientRepository.java
new file mode 100644
index 0000000..cbb3ae3
--- /dev/null
+++ b/src/main/java/cn/flaty/NettyPush/repository/H2ClientRepository.java
@@ -0,0 +1,54 @@
+package cn.flaty.NettyPush.repository;
+
+import java.util.Date;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+import cn.flaty.NettyPush.entity.packet.ClientPacket;
+import cn.flaty.NettyPush.entity.persitence.Client;
+
+@Repository
+public class H2ClientRepository implements ClientRepository {
+
+ @Autowired
+ private JdbcTemplateWrapper jdbc;
+
+ @Override
+ public boolean insertClient(ClientPacket c) {
+ // 设置过期时间
+ long expireTime = new Date(new Date().getTime()
+ + ClientRepository.client_db_live_time).getTime();
+ String sql = " insert into tb_online_client(appkey,did,expireTime,appVer,os) values(?,?,?,?,?)";
+ return jdbc.saveORUpdate(sql, new Object[] { c.getAppKey(), c.getDid(),
+ expireTime, c.getAppVer(), c.getOs() }) == 1;
+ }
+
+ @Override
+ public List queryClients(String appKey) {
+ String sql = " select appkey,did,expireTime from tb_online_client where appkey = ? and expireTime > ? ";
+ return jdbc
+ .queryForBeanList(sql, Client.class, new Object[] { appKey ,new Date().getTime()});
+ }
+
+ @Override
+ public boolean delExpireClient() {
+ String sql = " delete from tb_online_client where expireTime < ? ";
+ return jdbc.saveORUpdate(sql, new Object[] { new Date().getTime() }) >= 1;
+ }
+
+ @Override
+ public boolean touchClient(ClientPacket c) {
+ String sql = " update tb_online_client set expireTime = ? where did = ?";
+ return jdbc.saveORUpdate(sql,
+ new Object[] { new Date().getTime() + ClientRepository.client_db_live_time , c.getDid() }) == 1;
+ }
+
+ @Override
+ public Client getClient(String did) {
+ String sql = " select appkey,did,expireTime from tb_online_client where did = ?";
+ return jdbc.queryForBean(sql, Client.class, new Object[] { did });
+ }
+
+}
diff --git a/src/main/java/cn/flaty/NettyPush/clientRepo/jdbcWrapper/JdbcTemplateWrapper.java b/src/main/java/cn/flaty/NettyPush/repository/JdbcTemplateWrapper.java
similarity index 55%
rename from src/main/java/cn/flaty/NettyPush/clientRepo/jdbcWrapper/JdbcTemplateWrapper.java
rename to src/main/java/cn/flaty/NettyPush/repository/JdbcTemplateWrapper.java
index fb07834..37f2e64 100644
--- a/src/main/java/cn/flaty/NettyPush/clientRepo/jdbcWrapper/JdbcTemplateWrapper.java
+++ b/src/main/java/cn/flaty/NettyPush/repository/JdbcTemplateWrapper.java
@@ -1,55 +1,41 @@
-package cn.flaty.NettyPush.clientRepo.jdbcWrapper;
+package cn.flaty.NettyPush.repository;
-
-import java.text.MessageFormat;
import java.util.Arrays;
import java.util.List;
-import org.apache.log4j.Logger;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
-import cn.flaty.NettyPush.base.PageBean;
-import cn.flaty.NettyPush.base.QueryPageObject;
-import cn.flaty.NettyPush.clientRepo.pageSetter.PageSqlSetter;
-
-
/**
* Spring jdbcTemplate 包装器类，提供基本SQL操作
- *
+ *
* @author flatychen
- *
+ *
*/
@Component
public class JdbcTemplateWrapper {
- private static Logger log = Logger.getLogger(JdbcTemplateWrapper.class);
+ private static Logger log = LoggerFactory
+ .getLogger(JdbcTemplateWrapper.class);
@Autowired
private JdbcTemplate jdbcTemplate;
-
+
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
- public void setPageSqlSetter(PageSqlSetter pageSqlSetter) {
- this.pageSqlSetter = pageSqlSetter;
- }
-
- private PageSqlSetter pageSqlSetter;
-
private final List query(String sql, Class clazz, Object args[]) {
List l = null;
try {
- if (log.isInfoEnabled()) {
- log.info(MessageFormat.format(
- "======>>query'{' sql:{1}, args:{3} '}'", 1, sql, 3,
- Arrays.toString(args)));
- }
+ log.info("====>>query{ sql:{}, args:{} }", sql,
+ Arrays.toString(args));
l = this.jdbcTemplate.query(sql, args,
new BeanPropertyRowMapper(clazz));
} catch (DataAccessException e) {
@@ -61,7 +47,7 @@ private final List query(String sql, Class clazz, Object args[]) {
/**
* class得到对象
- *
+ *
* @param sql
* @param clazz
* @param args
@@ -81,7 +67,7 @@ public final T queryForBean(String sql, Class clazz, Object args[]) {
/**
* class得到对象list
- *
+ *
* @param sql
* @param clazz
* @param args
@@ -97,7 +83,7 @@ public final List queryForBeanList(String sql, Class clazz,
/**
* 返回 long --> count(1)
- *
+ *
* @param sql
* @param args
* @return
@@ -105,18 +91,15 @@ public final List queryForBeanList(String sql, Class clazz,
* @date 2014-1-10
*/
public final long queryForLong(String sql, Object args[]) {
- if (log.isInfoEnabled()) {
- log.info(MessageFormat.format(
- "======>>queryForLong[ sql:[ {1} ] , args:[ {3} ] ]", 1,
- sql, 3, Arrays.toString(args)));
- }
+ log.info("====>>queryForLong[ sql:[ {} ] , args:[ {} ] ]", sql,
+ Arrays.toString(args));
return this.jdbcTemplate.queryForLong(sql, args);
}
/**
* 返回 int -->count(1)
- *
+ *
* @param sql
* @param args
* @return
@@ -124,19 +107,15 @@ public final long queryForLong(String sql, Object args[]) {
* @date 2014-1-10
*/
public final int queryForInt(String sql, Object args[]) {
- if (log.isInfoEnabled()) {
- log.info(MessageFormat.format(
- "======>>queryForInt[ sql:[ {1} ] , args:[ {3} ] ]", 1,
- sql, 3, Arrays.toString(args)));
- }
+ log.info("====>>queryForInt[ sql:[ {} ] , args:[ {} ] ]", sql,
+ Arrays.toString(args));
return this.jdbcTemplate.queryForInt(sql, args);
}
-
-
+
/**
- * 返回 object eg: Integer,Object
- *
+ * 返回 object eg: Integer,Object
+ *
* @param sql
* @param args
* @return
@@ -144,18 +123,15 @@ public final int queryForInt(String sql, Object args[]) {
* @param
* @date 2014-1-10
*/
- public final T queryForObject(String sql, Class clazz,Object args[]) {
- if (log.isInfoEnabled()) {
- log.info(MessageFormat.format(
- "======>>queryForObject[ sql:[ {1} ] , args:[ {3} ] ]", 1,
- sql, 3, Arrays.toString(args)));
- }
+ public final T queryForObject(String sql, Class clazz, Object args[]) {
+ log.info("====>>queryForObject[ sql:[{}] , args:[{}] ]", sql,
+ Arrays.toString(args));
return this.jdbcTemplate.queryForObject(sql, clazz, args);
}
/**
- *
+ *
* @author flatychen
* @param sql
* @param args
@@ -163,11 +139,8 @@ public final T queryForObject(String sql, Class clazz,Object args[]) {
* @date 2014-1-12
*/
public int saveORUpdate(String sql, Object args[]) {
- if (log.isInfoEnabled()) {
- log.info(MessageFormat.format(
- "======>>saveORUpdate[ sql:[ {1} ] , args:[ {3} ] ]", 1,
- sql, 3, Arrays.toString(args)));
- }
+ log.info("====>>saveORUpdate[ sql:[ {} ] , args:[ {} ] ]", sql,
+ Arrays.toString(args));
int num = 0;
try {
num = jdbcTemplate.update(sql, args);
@@ -180,18 +153,15 @@ public int saveORUpdate(String sql, Object args[]) {
/**
* 批量更新
- *
+ *
* @author flatychen
* @param sql
* @param listArgs
* @return
*/
public int batchUpdate(String sql, List listArgs) {
- if (log.isInfoEnabled()) {
- log.info(MessageFormat.format(
- "======>>batchInsert[ sql:[ {1} ] , args:[ {3} ] ]", 1,
- sql, 3, Arrays.toString(listArgs.toArray())));
- }
+ log.info("====>>batchInsert[ sql:[ {} ] , args:[ {} ] ]", sql,
+ Arrays.toString(listArgs.toArray()));
int num[] = null;
try {
num = jdbcTemplate.batchUpdate(sql, listArgs);
@@ -202,27 +172,4 @@ public int batchUpdate(String sql, List listArgs) {
return num.length;
}
- /**
- * 分页方法
- * @author flatychen
- * @param pageSize
- * @param toPage
- * @param sql
- * @param clazz
- * @param args
- * @return
- */
- public PageBean queryForPage(QueryPageObject query, String sql,
- Class clazz, Object[] args) {
- String countSql = pageSqlSetter.getCountSql(sql);
- String querySql = pageSqlSetter.getQuerySql(sql);
-
- int totalRow = this.queryForInt(countSql, args);
- List list = this.queryForBeanList(querySql, clazz, args);
-
- PageBean page = new PageBean(query.getPageNo(),query.getPageSize(),totalRow,list);
- return page;
-
- }
-
}
diff --git a/src/main/java/cn/flaty/NettyPush/repository/MysqlClientRepository.java b/src/main/java/cn/flaty/NettyPush/repository/MysqlClientRepository.java
new file mode 100644
index 0000000..d9d6dc7
--- /dev/null
+++ b/src/main/java/cn/flaty/NettyPush/repository/MysqlClientRepository.java
@@ -0,0 +1,47 @@
+package cn.flaty.NettyPush.repository;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import cn.flaty.NettyPush.entity.packet.ClientPacket;
+import cn.flaty.NettyPush.entity.persitence.Client;
+
+//@Repository
+public class MysqlClientRepository implements ClientRepository {
+
+ @Autowired
+ private JdbcTemplateWrapper jdbc;
+
+ @Override
+ public boolean insertClient(ClientPacket c) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public Client getClient(String did) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public List queryClients(String appKey) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+
+ @Override
+ public boolean delExpireClient() {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public boolean touchClient(ClientPacket c) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+}
diff --git a/src/main/java/cn/flaty/NettyPush/server/DefaultListener.java b/src/main/java/cn/flaty/NettyPush/server/DefaultListener.java
index 6249549..8b2a969 100644
--- a/src/main/java/cn/flaty/NettyPush/server/DefaultListener.java
+++ b/src/main/java/cn/flaty/NettyPush/server/DefaultListener.java
@@ -29,6 +29,7 @@
* @author flaty
*
*/
+
public class DefaultListener implements Listener{
private Logger log = LoggerFactory.getLogger(DefaultListener.class);
@@ -50,7 +51,7 @@ public void start() {
ServerBootstrap sbs = new ServerBootstrap();
sbs.group(acceptor, worker).channel(NioServerSocketChannel.class)
// .childOption(ChannelOption.SO_KEEPALIVE, true)
-// .childOption(ChannelOption.TCP_NODELAY, true)
+ .childOption(ChannelOption.TCP_NODELAY, true) // 禁止 Nagle算法
// .childOption(ChannelOption.SO_REUSEADDR, true)
.childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT) // 使用内存池 回收堆外内存
// .childOption(ChannelOption.MESSAGE_SIZE_ESTIMATOR, new MessageSizeEstimator() {
diff --git a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/AbstractChannelInitializer.java b/src/main/java/cn/flaty/NettyPush/server/channelInitializer/AbstractChannelInitializer.java
index 43b8f5d..aeff63a 100644
--- a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/AbstractChannelInitializer.java
+++ b/src/main/java/cn/flaty/NettyPush/server/channelInitializer/AbstractChannelInitializer.java
@@ -5,6 +5,15 @@
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
+/**
+ *
+ * 抽像ChannelInitializer
+ *
+ * 用于组织不同的channel
+ *
+ * @author flatychen
+ *
+ */
public abstract class AbstractChannelInitializer extends ChannelInitializer {
private ChannelHandler[] inHandlers;
@@ -27,7 +36,7 @@ protected void initChannel(Channel ch) throws Exception {
}
this.initPipeline(pipeline);
if (outHandlers != null) {
- //pipeline.addl(outHandlers);
+ // pipeline.addl(outHandlers);
}
}
diff --git a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/HttpChannelInitializer.java b/src/main/java/cn/flaty/NettyPush/server/channelInitializer/HttpChannelInitializer.java
deleted file mode 100644
index a02130b..0000000
--- a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/HttpChannelInitializer.java
+++ /dev/null
@@ -1,30 +0,0 @@
-package cn.flaty.NettyPush.server.channelInitializer;
-
-import cn.flaty.NettyPush.server.handler.HttpDemoHandler;
-import io.netty.channel.ChannelPipeline;
-import io.netty.handler.codec.http.HttpRequestDecoder;
-import io.netty.handler.codec.http.HttpResponseEncoder;
-
-public class HttpChannelInitializer extends AbstractChannelInitializer{
-
- private static String HTTPDECODER = "httpDecoder";
- private static String HTTPENCODER = "httpEncoder";
-
- @Override
- protected void initPipeline(ChannelPipeline pipeline) {
- this.addBaseChannel(pipeline);
-
- this.addCustomChannel(pipeline);
- }
-
- private void addCustomChannel(ChannelPipeline pipeline) {
- pipeline.addLast(new HttpDemoHandler());
-
- }
-
- private void addBaseChannel(ChannelPipeline pipeline){
- pipeline.addFirst(HTTPDECODER, new HttpRequestDecoder());
- pipeline.addFirst(HTTPENCODER, new HttpResponseEncoder());
- }
-
-}
diff --git a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/PushChannelInitializer.java b/src/main/java/cn/flaty/NettyPush/server/channelInitializer/PushChannelInitializer.java
index 2265277..0a2c4d6 100644
--- a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/PushChannelInitializer.java
+++ b/src/main/java/cn/flaty/NettyPush/server/channelInitializer/PushChannelInitializer.java
@@ -2,9 +2,6 @@
import io.netty.channel.ChannelPipeline;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Required;
import cn.flaty.NettyPush.server.codec.push.DeserializeHandler;
@@ -14,27 +11,34 @@
import cn.flaty.NettyPush.server.codec.push.SplitFrameDecoder;
import cn.flaty.NettyPush.server.frame.FrameHead;
-public class PushChannelInitializer extends AbstractChannelInitializer{
+/**
+ *
+ * 推送channel pipeline
+ *
+ * @author flatychen
+ *
+ */
+public class PushChannelInitializer extends AbstractChannelInitializer {
-
- private static Logger log = LoggerFactory.getLogger(PushChannelInitializer.class);
-
private FrameHead frameHeader;
-
+
@Override
protected void initPipeline(ChannelPipeline pipeline) {
- // 解码器
+
+ // 切包,粘包
pipeline.addLast(new SplitFrameDecoder(frameHeader));
+ // 解码
pipeline.addLast(new PushFrameDecoder(frameHeader));
-
+
// 编码器
+ // 粘包
pipeline.addLast(new MergeFrameEncoder(frameHeader));
-
+ // 编码
pipeline.addLast(new PushFrameEncoder(frameHeader));
-
+
+ // 业务处理
pipeline.addLast(new DeserializeHandler());
-
-
+
}
@Required
@@ -42,5 +46,4 @@ public void setFrameHeader(FrameHead frameHeader) {
this.frameHeader = frameHeader;
}
-
}
diff --git a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/SocketChannelInitializer.java b/src/main/java/cn/flaty/NettyPush/server/channelInitializer/SocketChannelInitializer.java
deleted file mode 100644
index 3b49b7d..0000000
--- a/src/main/java/cn/flaty/NettyPush/server/channelInitializer/SocketChannelInitializer.java
+++ /dev/null
@@ -1,31 +0,0 @@
-package cn.flaty.NettyPush.server.channelInitializer;
-
-import io.netty.channel.ChannelPipeline;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import cn.flaty.NettyPush.server.codec.push.DeserializeHandler;
-import cn.flaty.NettyPush.server.codec.push.PushFrameDecoder;
-import cn.flaty.NettyPush.server.codec.push.SplitFrameDecoder;
-
-public class SocketChannelInitializer extends AbstractChannelInitializer{
-
-
- private static Logger log = LoggerFactory.getLogger(SocketChannelInitializer.class);
-
- @Override
- protected void initPipeline(ChannelPipeline pipeline) {
-
- // 解码器
-
-
-
- // 编码器
- //pipeline.addLast(new PushFrameDecoder());
- //pipeline.addLast(new PushFrameDecoder());
-
- }
-
-
-}
diff --git a/src/main/java/cn/flaty/NettyPush/server/codec/push/DeserializeHandler.java b/src/main/java/cn/flaty/NettyPush/server/codec/push/DeserializeHandler.java
index 1479885..e919c45 100644
--- a/src/main/java/cn/flaty/NettyPush/server/codec/push/DeserializeHandler.java
+++ b/src/main/java/cn/flaty/NettyPush/server/codec/push/DeserializeHandler.java
@@ -1,22 +1,26 @@
package cn.flaty.NettyPush.server.codec.push;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springframework.beans.BeansException;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
import cn.flaty.NettyPush.server.conn.NettyConnection;
import cn.flaty.NettyPush.services.ClientDispacherService;
import cn.flaty.NettyPush.utils.beanFactoryUtils;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
-import io.netty.channel.SimpleChannelInboundHandler;
+/**
+ *
+ * 业务处理.
+ *
+ * @author flatychen
+ *
+ */
public class DeserializeHandler extends SimpleChannelInboundHandler {
-
+
private ClientDispacherService deserialize;
-
+
private Logger log = LoggerFactory.getLogger(DeserializeHandler.class);
public DeserializeHandler() {
@@ -27,12 +31,10 @@ public DeserializeHandler() {
@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg)
throws Exception {
- log.info(msg.length()+"");
- log.info(msg);
+ log.info("receive msg:{}", msg);
+ // 分发
NettyConnection conn = new NettyConnection(ctx);
deserialize.dispacher(conn, msg);
}
-
-
}
\ No newline at end of file
diff --git a/src/main/java/cn/flaty/NettyPush/server/codec/push/PushFrameDecoder.java b/src/main/java/cn/flaty/NettyPush/server/codec/push/PushFrameDecoder.java
index dce4b70..b5b0681 100644
--- a/src/main/java/cn/flaty/NettyPush/server/codec/push/PushFrameDecoder.java
+++ b/src/main/java/cn/flaty/NettyPush/server/codec/push/PushFrameDecoder.java
@@ -4,6 +4,7 @@
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
+import java.net.InetSocketAddress;
import java.util.List;
import org.slf4j.Logger;
@@ -13,35 +14,46 @@
import cn.flaty.NettyPush.server.frame.SimplePushInFrame;
import cn.flaty.NettyPush.utils.AssertUtils;
+/**
+ *
+ * 根据包头解码
+ *
+ * @author flatychen
+ *
+ */
public class PushFrameDecoder extends ByteToMessageDecoder {
-
- private Logger log = LoggerFactory.getLogger(PushFrameDecoder.class);
+
+ private Logger log = LoggerFactory.getLogger(PushFrameDecoder.class);
private FrameHead frameHead;
public PushFrameDecoder(FrameHead frameHead) {
super();
- AssertUtils.notNull(frameHead, "----> frameHead 不能为空 ");
+ AssertUtils.notNull(frameHead, " frameHead 不能为空 ");
this.frameHead = frameHead;
}
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in,
List