| 
					
				 | 
			
			
				@ -36,6 +36,7 @@ public class RedisThread implements Runnable { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    private PushMsgTask pushMsgTask; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    //redis链接池 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    private JedisPool pool; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    private Jedis jedis; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    @Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    public void run() { 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -45,7 +46,6 @@ public class RedisThread implements Runnable { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        while (true){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                Jedis jedis = pool.getResource(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                String message = jedis.rpop(key); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                if(StringUtils.isEmpty(message)){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    sleep(1000L);//如果没有读取到记录,等待1秒 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -80,6 +80,7 @@ public class RedisThread implements Runnable { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        }else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            pool = new JedisPool(poolConfig,host,port,100000); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        jedis = pool.getResource(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    public void redisMessage(String message){ 
			 |