Shulou(Shulou.com)06/02 Report--

This article mainly introduces how SpringBoot2 integrates Redis Sentinel Cluster to realize the message queue scenario, which has certain reference value. Interested friends can refer to it. I hope you will learn a lot after reading this article. Let the editor take you to know it.

1. Brief introduction of Redis Cluster 1. RedisCluster concept

Redis's distributed solution, launched after version 3.0, effectively solves the Redis distributed requirements, when one service downtime can quickly switch to another service. Redis cluster is mainly aimed at massive data + high concurrency + high availability scenarios.

2. Integration with SpringBoot2.0 1, core dependence on org.springframework.boot spring-boot-starter-data-redis ${spring-boot.version} redis.clients jedis ${redis-client.version} 2, Core configuration spring: # Redis cluster redis: sentinel: # sentinel configuration master: mymaster nodes: 192.168.0.127 redis 26379 maxTotal: 60 minIdle: 10 maxWaitMillis: 10000 testWhileIdle: true testOnBorrow: true testOnReturn: false timeBetweenEvictionRunsMillis: 100003, parameter rendering class @ ConfigurationProperties (prefix = "spring.redis.sentinel") public class RedisParam {private String nodes Private String master; private Integer maxTotal; private Integer minIdle; private Integer maxWaitMillis; private Integer timeBetweenEvictionRunsMillis; private boolean testWhileIdle; private boolean testOnBorrow; private boolean testOnReturn; / omit GET and SET methods} 4, cluster configuration file @ Configuration@EnableConfigurationProperties (RedisParam.class) public class RedisPool {@ Resource private RedisParam redisParam; @ Bean ("jedisSentinelPool") public JedisSentinelPool getRedisPool () {Set sentinels = new HashSet () Sentinels.addAll (Arrays.asList (redisParam.getNodes (). Split (",")); GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig (); poolConfig.setMaxTotal (redisParam.getMaxTotal ()); poolConfig.setMinIdle (redisParam.getMinIdle ()); poolConfig.setMaxWaitMillis (redisParam.getMaxWaitMillis ()); poolConfig.setTestWhileIdle (redisParam.isTestWhileIdle ()); poolConfig.setTestOnBorrow (redisParam.isTestOnBorrow ()); poolConfig.setTestOnReturn (redisParam.isTestOnReturn ()) PoolConfig.setTimeBetweenEvictionRunsMillis (redisParam.getTimeBetweenEvictionRunsMillis ()); JedisSentinelPool redisPool = new JedisSentinelPool (redisParam.getMaster (), sentinels, poolConfig); return redisPool;} @ Bean SpringUtil springUtil () {return new SpringUtil ();} @ Bean RedisListener redisListener () {return new RedisListener () Configure Redis template class @ Configurationpublic class RedisConfig {@ Bean public StringRedisTemplate stringRedisTemplate (RedisConnectionFactory factory) {StringRedisTemplate stringRedisTemplate = new StringRedisTemplate (); stringRedisTemplate.setConnectionFactory (factory); return stringRedisTemplate;}} 3. Simulation queue scenario case

Producer-consumer model: the client listens to the message queue, the message arrives, and the consumer consumes it immediately. If there is no message in the message queue, the consumer continues to monitor. LPUSH (BLPUSH) based on Redis queues the message and uses RPOP (BRPOP) to get the mode of the message.

1. Lock and unlock tool @ Componentpublic class RedisLock {private static String keyPrefix = "RedisLock:"; @ Resource private JedisSentinelPool jedisSentinelPool; public boolean addLock (String key, long expire) {Jedis jedis = null; try {jedis = jedisSentinelPool.getResource () / * * the value of nxxx can only be NX or XX. If NX is used, set is performed only if key does not exist. If XX is taken, set is performed only if key already exists. The value of expx can only be EX or PX, which represents the unit of data expiration time. EX represents seconds and PX represents milliseconds. * / String value = jedis.set (keyPrefix + key, "1", "nx", "ex", expire); return value! = null;} catch (Exception e) {e.printStackTrace ();} finally {if (jedis! = null) jedis.close ();} return false } public void removeLock (String key) {Jedis jedis = null; try {jedis = jedisSentinelPool.getResource (); jedis.del (keyPrefix + key);} finally {if (jedis! = null) jedis.close ();} 2, message consumption

1) encapsulate the interface

Public interface RedisHandler {/ * * queue name * / String queueName (); / * queue message content * / String consume (String msgBody);}

2) Interface implementation

@ Componentpublic class LogAListen implements RedisHandler {private static final Logger LOG = LoggerFactory.getLogger (LogAListen.class); @ Resource private RedisLock redisLock; @ Override public String queueName () {return "LogA-key";} @ Override public String consume (String msgBody) {/ / locked to prevent repeated delivery of messages String lockKey = "lock-order-uuid-A"; boolean lock = false Try {lock = redisLock.addLock (lockKey, 60); if (! lock) {return "success";} LOG.info ("LogA-key = = > >" + msgBody);} catch (Exception e) {e.printStackTrace () } finally {if (lock) {redisLock.removeLock (lockKey);}} return "success";}} 3, message listener public class RedisListener implements InitializingBean {/ * Redis cluster * / @ Resource private JedisSentinelPool jedisSentinelPool; private List handlers = null; private ExecutorService product = null; private ExecutorService consumer = null / * initialize the configuration * / @ Override public void afterPropertiesSet () {handlers = SpringUtil.getBeans (RedisHandler.class); product = new ThreadPoolExecutor (10min15, 60 * 3, TimeUnit.SECONDS,new SynchronousQueue ()); consumer = new ThreadPoolExecutor (10p15, 60 * 3, TimeUnit.SECONDS,new SynchronousQueue ()) For (RedisHandler redisHandler: handlers) {product.execute (()-> {redisTask (redisHandler);});}} / * queue snooping * / public void redisTask (RedisHandler redisHandler) {Jedis jedis = null; while (true) {try {jedis = jedisSentinelPool.getResource () List msgBodyList = jedis.brpop (0, redisHandler.queueName ()); if (msgBodyList! = null & & msgBodyList.size () > 0) {consumer.execute (()-> {redisHandler.consume (msgBodyList.get (1));}) } catch (Exception e) {e.printStackTrace ();} finally {if (jedis! = null) jedis.close ();} 4, message producer @ Servicepublic class RedisServiceImpl implements RedisService {@ Resource private JedisSentinelPool jedisSentinelPool; @ Override public void saveQueue (String queueKey, String msgBody) {Jedis jedis = null Try {jedis = jedisSentinelPool.getResource (); jedis.lpush (queueKey,msgBody);} catch (Exception e) {e.printStackTrace ();} finally {if (jedis! = null) jedis.close ();} 5, scenario test interface @ RestControllerpublic class RedisController {@ Resource private RedisService redisService / * RequestMapping ("/ saveQueue") public String saveQueue () {MsgBody msgBody = new MsgBody (); msgBody.setName ("LogAModel"); msgBody.setDesc ("description"); msgBody.setCreateTime (new Date ()); redisService.saveQueue ("LogA-key", JSONObject.toJSONString (msgBody)); return "success" }} Thank you for reading this article carefully. I hope the article "how SpringBoot2 integrates Redis Sentinel Cluster to achieve message queuing scenario" shared by the editor will be helpful to you. At the same time, I hope you will support us and pay attention to the industry information channel. More related knowledge is waiting for you to learn!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.