springboot2整合activemq的demo内含queue消息和topic消息

package com.springboot2.util; import com.springboot2.config.RedisConfig; import org.springframework.beans.factory.annotation.Autowired; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import redis.clients.jedis.SortingParams; import redis.clients.util.SafeEncoder; import javax.annotation.Resource; import java.util.*; import java.util.concurrent.locks.ReentrantLock; public class RedisUtil { @Resource RedisConfig redisConfig; //默认缓存时间 private static final int EXPIRE = 60000; private static Properties properties; private static RedisUtil instance; private static JedisPool jedisPool; private static ReentrantLock lock = new ReentrantLock(); private RedisUtil() { } public static RedisUtil getInstance() { if (instance == null) { lock.lock(); if (instance == null) { instance = new RedisUtil(); } lock.unlock(); } return instance; } /** * 初始化JedisPool */ private void initJedisPool() { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(3); jedisPool = new JedisPool(config,"127.0.0.1",6379,3000,""); } /** * 通用方法：从JedisPool中获取Jedis * * @return */ private Jedis getJedis() { if (jedisPool == null) { lock.lock(); //防止吃初始化时多线程竞争问题 initJedisPool(); lock.unlock(); } return jedisPool.getResource(); } /** * 通用方法：释放Jedis * * @param jedis */ private void closeJedis(Jedis jedis) { jedis.close(); } //=========================================================== /** * 对Keys,以及存储结构为String、List、Set、HashMap类型的操作 */ private final Keys keys = new Keys(); private final Strings strings = new Strings(); private final Lists lists = new Lists(); private final Sets sets = new Sets(); private final Hash hash = new Hash(); private final SortSet sortset = new SortSet(); public Keys keys() { return keys; } public Strings strings() { return strings; } public Lists lists() { return lists; } public Sets sets() { return sets; } public Hash hash() { return hash; } public SortSet sortSet() { return sortset; } //=========================================================== //*******************************************Keys*******************************************// public class Keys { /** * 设置过期时间 * * @param key * @param seconds * @return 返回影响的记录数 */ public long expire(String key, int seconds) { if (seconds <= 0) { return -1L; } Jedis jedis = getJedis(); long result = jedis.expire(key, seconds); closeJedis(jedis); return result; } /** * 设置过期时间，默认值为60000seconds * * @param key */ public long expire(String key) { return expire(key, EXPIRE); } /** * 设置key的过期时间,它是距历元（即格林威治标准时间 1970 年 1 月 1 日的 00:00:00，格里高利历）的偏移量。 * * @param key * @param timestamp 秒 * @return 影响的记录数 */ public long expireAt(String key, long timestamp) { Jedis jedis = getJedis(); long count = jedis.expireAt(key, timestamp); closeJedis(jedis); return count; } /** * 查询key的过期时间 * * @param key * @return 以秒为单位的时间表示 */ public long ttl(String key) { //ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); long len = sjedis.ttl(key); closeJedis(sjedis); return len; } /** * 取消对key过期时间的设置 * * @param key * @return 影响的记录数 */ public long persist(String key) { Jedis jedis = getJedis(); long count = jedis.persist(key); closeJedis(jedis); return count; } /** * 清空所有key * * @return */ public String flushAll() { Jedis jedis = getJedis(); String stata = jedis.flushAll(); closeJedis(jedis); return stata; } /** * 判断key是否存在 * * @param key * @return boolean */ public boolean exists(String key) { Jedis sjedis = getJedis(); boolean exis = sjedis.exists(key); closeJedis(sjedis); return exis; } /** * 更改key */ public String rename(String oldKey, String newKey) { return rename(SafeEncoder.encode(oldKey),SafeEncoder.encode(newKey)); } /** * 更改key,仅当新key不存在时才执行 * * @param oldKey * @param newKey * @return 状态码 */ public long renamenx(String oldKey, String newKey) { Jedis jedis = getJedis(); long status = jedis.renamenx(oldKey, newKey); closeJedis(jedis); return status; } /** * 更改key */ public String rename(byte[] oldKey, byte[] newKey) { Jedis jedis = getJedis(); String status = jedis.rename(oldKey, newKey); closeJedis(jedis); return status; } /** * 删除keys对应的记录,可以是多个key * * @param keys * @return 删除的记录数 */ public long del(String... keys) { Jedis jedis = getJedis(); long count = jedis.del(keys); closeJedis(jedis); return count; } /** * 删除keys对应的记录,可以是多个key * * @param keys * @return 删除的记录数 */ public long del(byte[]... keys) { Jedis jedis = getJedis(); long count = jedis.del(keys); closeJedis(jedis); return count; } /** * 对List,Set,SortSet进行排序,如果集合数据较大应避免使用这个方法 * * @param key * @return List<String> 集合的全部记录 **/ public List<String> sort(String key) { Jedis sjedis = getJedis(); List<String> list = sjedis.sort(key); closeJedis(sjedis); return list; } /** * 对List,Set,SortSet进行排序或limit * * @param key * @param parame 定义排序类型或limit的起止位置. * @return List<String> 全部或部分记录 **/ public List<String> sort(String key, SortingParams parame) { Jedis jedis = getJedis(); List<String> list = jedis.sort(key, parame); closeJedis(jedis); return list; } /** * 返回指定key存储的类型 * * @param key * @return String string|list|set|zset|hash **/ public String type(String key) { Jedis sjedis = getJedis(); String type = sjedis.type(key); closeJedis(sjedis); return type; } /** * 查找所�