netty应用于物联网或者即时通讯项目

netty 物联网iot中mqtt 服务器端开发，主要是使用技术springboot+mqtt3.1.1+netty

package io.mqttpush.mqttclient.conn;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Future;
import java.util.concurrent.linkedBlockingQueue;
import java.util.concurrent.ScheduledThreadPoolExecutor;

/**
 * 取消执行的线程池
 * @author tianzhenjiu
 *
 */
public class CancelbleExecutorService extends ScheduledThreadPoolExecutor{

	
	BlockingQueue> futures=new linkedBlockingQueue<>（1024）;
	public CancelbleExecutorService（int corePoolSize） {
		super（corePoolSize）;
		
	}

	
	/**
	 * 删除所有已有的任务
	 */
	public void reset（） {
		BlockingQueue blockingQueue=super.getQueue（）;
		if（blockingQueue!=null） {
			blockingQueue.forEach（（b）->{
				CancelbleExecutorService.this.remove（b）;
			}）;
		}
		
	}

	
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2019-01-09 09:12  mqtt-push\
     文件         234  2019-01-09 09:12  mqtt-push\.gitignore
     文件         864  2019-01-09 09:12  mqtt-push\README.md
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-admin\
     文件         425  2019-01-09 09:12  mqtt-push\mqtt-admin\pom.xml
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\
     文件         427  2019-01-09 09:12  mqtt-push\mqtt-commons\pom.xml
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\
     文件         766  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\CancelbleExecutorService.java
     文件        1457  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\ConnectProperties.java
     文件        4440  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\Connetor.java
     文件         295  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\Status.java
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\
     文件        4707  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\ConnectionHandle.java
     文件        2335  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\PingRunnable.java
     文件        4040  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\PubHandle.java
     文件         944  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\SubHandle.java
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\
     文件         582  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\ApiService.java
     文件        5049  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\DefaultApiService.java
     文件         446  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\DefaultMessageListener.java
     文件         281  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\MessageListener.java
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttserver\
     目录           0  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttserver\beans\
     文件        1488  2019-01-09 09:12  mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttserver\beans\ConstantBean.java
............此处省略134个文件信息