| 
					
				 | 
			
			
				@@ -16,7 +16,6 @@ import java.util.Map; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.slf4j.Logger; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.slf4j.LoggerFactory; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.beans.factory.annotation.Autowired; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.stereotype.Component; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.smartsanitation.common.util.StringUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.tidecloud.dataacceptance.entity.Advice; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -26,6 +25,7 @@ import com.tidecloud.dataacceptance.entity.Device; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import io.netty.buffer.ByteBuf; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import io.netty.buffer.Unpooled; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import io.netty.channel.Channel; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+import io.netty.channel.ChannelHandler.Sharable; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import io.netty.channel.ChannelHandlerContext; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import io.netty.channel.ChannelInboundHandlerAdapter; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import redis.clients.jedis.Jedis; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -34,7 +34,7 @@ import redis.clients.jedis.JedisPool; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 /** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  * Created by vinson on 2017/9/7. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  */ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-@Component 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+@Sharable 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 public class DiscardServerHandler extends ChannelInboundHandlerAdapter { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				      
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private String dataPath = "/home/service/collector_watch/rawdata/"; 
			 |