2.工具类编写

注意连接池的配置，maxTotal最大连接数各个端可做调整，建议司机端1000，订单500，乘客500，后台500

PikaUtil.java

package com.visionet.core.util;import com.visionet.core.redis.SerializeUtil;
import com.visionet.user.dome.CarWorkDto;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;import java.util.ArrayList;
import java.util.List;
import java.util.Set;/*** pika存储，目前专门用来存储司机GPS轨迹，其他信息存储请勿使用** @author yang_tao@<yangtao.letzgo.com.cn>* @version 1.0* @date 2018-03-28 9:50*/
public class PikaUtil {private static final Logger LOGGER = LoggerFactory.getLogger(PikaUtil.class);private static JedisPool jedisPool;static {try {String ip = ResourceUtil.getValueBykey("base", "pika.ip");String port = ResourceUtil.getValueBykey("base", "pika.port");String auth = ResourceUtil.getValueBykey("base", "pika.auth");JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxTotal(1000);poolConfig.setMaxIdle(10);poolConfig.setMaxWaitMillis(500);poolConfig.setTestWhileIdle(true);poolConfig.setTimeBetweenEvictionRunsMillis(30 * 60 * 1000L);poolConfig.setSoftMinEvictableIdleTimeMillis(10 * 60 * 1000L);if (StringUtils.isBlank(auth)) {jedisPool = new JedisPool(poolConfig, ip, Integer.parseInt(port), 1000);} else {jedisPool = new JedisPool(poolConfig, ip, Integer.parseInt(port), 1000, auth);}} catch (Exception e) {LOGGER.error("初始Pika连接池异常:{}", ExceptionStackTraceUtils.getStackTrace(e));}}public static void addToCarGpsList(String key, CarWorkDto carWorkDto) {try (Jedis jedis = jedisPool.getResource()) {jedis.rpush(listKey(key).getBytes(), SerializeUtil.serialize(carWorkDto));} catch (Exception e) {LOGGER.error("上传GPS轨迹异常:{}", ExceptionStackTraceUtils.getStackTrace(e));}}@SuppressWarnings("unchecked")public static <T> List<T> getCarGpsList(String key) {List<T> list = new ArrayList<>();try (Jedis jedis = jedisPool.getResource()) {List<byte[]> bytes = jedis.lrange(listKey(key).getBytes(), 0, -1);if (bytes != null && !bytes.isEmpty()) {bytes.forEach(item -> list.add((T) SerializeUtil.unserialize(item)));}} catch (Exception e) {LOGGER.error("获取key={}的GPS列表异常:{}", key, ExceptionStackTraceUtils.getStackTrace(e));}return list;}/*** 删除指定key的GPS信息，谨慎使用** @param key* @return*/public static Long deleteCarGpsList(String key) {try (Jedis jedis = jedisPool.getResource()) {return jedis.del(listKey(key));} catch (Exception e) {LOGGER.error("删除key={}异常:{}", key, ExceptionStackTraceUtils.getStackTrace(e));}return 0L;}/*** 获取所有符合条件的GPS key** @param key* @return*/public static Set<String> getCarGpsKeys(String key) {try (Jedis jedis = jedisPool.getResource()) {return jedis.keys(listKey(key));} catch (Exception e) {LOGGER.error("获取keys={}异常:{}", key, ExceptionStackTraceUtils.getStackTrace(e));}return null;}/*** pika是允许不同的数据结构存在相同的key的，所以每个数据结构需要加特定后缀进行区分** @param key* @return*/private static String listKey(String key) {return key + "_LIST";}}

3.引用的地方进行修改，具体根据各个端原有代码进行修改即可。

ex：司机端RedisUtil.setObjectListData(*,*)替换为PikaUtil.addToCarGpsList(*,*)