{
-
- private static final long serialVersionUID = -265236426751004839L;
-
- private StandardThreadExecutor threadPoolExecutor;
-
- public ExecutorQueue() {
- super();
- }
-
- public void setStandardThreadExecutor(StandardThreadExecutor threadPoolExecutor) {
- this.threadPoolExecutor = threadPoolExecutor;
- }
-
- // 注：代码来源于 tomcat
- public boolean force(Runnable o) {
- if (threadPoolExecutor.isShutdown()) {
- throw new RejectedExecutionException("Executor not running, can't force a command into the queue");
- }
- // forces the item onto the queue, to be used if the task is rejected
- return super.offer(o);
- }
-
- // 注：tomcat的代码进行一些小变更
- public boolean offer(Runnable o) {
- int poolSize = threadPoolExecutor.getPoolSize();
-
- // we are maxed out on threads, simply queue the object
- if (poolSize == threadPoolExecutor.getMaximumPoolSize()) {
- return super.offer(o);
- }
- // we have idle threads, just add it to the queue
- // note that we don't use getActiveCount(), see BZ 49730
- if (poolSize >= threadPoolExecutor.getSubmittedTasksCount()) {
- return super.offer(o);
- }
- // if we have less threads than maximum force creation of a new
- // thread
- if (poolSize < threadPoolExecutor.getMaximumPoolSize()) {
- return false;
- }
- // if we reached here, we need to add it to the queue
- return super.offer(o);
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/pool/StandardThreadExecutor.java b/src/main/java/com/github/unclecatmyself/common/pool/StandardThreadExecutor.java
deleted file mode 100644
index 6fdab50..0000000
--- a/src/main/java/com/github/unclecatmyself/common/pool/StandardThreadExecutor.java
+++ /dev/null
@@ -1,98 +0,0 @@
-package com.github.unclecatmyself.common.pool;
-
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.AtomicInteger;
-
-/**
- * Create by UncleCatMySelf in 2018/12/06
- * tomcat: org.apache.catalina.core.StandardThreadExecutor
- *
- * java.util.concurrent.threadPoolExecutor execute执行策略:
- * 优先offer到queue，queue满后再扩充线程到maxThread，如果已经到了maxThread就reject
- * 比较适合于CPU密集型应用（比如runnable内部执行的操作都在JVM内部，memory copy, or compute等等）
- *
- * StandardThreadExecutor execute执行策略：
- * 优先扩充线程到maxThread，再offer到queue，如果满了就reject
- * 比较适合于业务处理需要远程资源的场景
- **/
-public class StandardThreadExecutor extends ThreadPoolExecutor {
-
- public static final int DEFAULT_MIN_THREADS = 20;
- public static final int DEFAULT_MAX_THREADS = 200;
- public static final int DEFAULT_MAX_IDLE_TIME = 60000; // 1 minutes
-
- protected AtomicInteger submittedTasksCount; // 正在处理的任务数
- private int maxSubmittedTaskCount; // 最大允许同时处理的任务数
-
- public StandardThreadExecutor() {
- this(DEFAULT_MIN_THREADS, DEFAULT_MAX_THREADS);
- }
-
- public StandardThreadExecutor(int coreThread, int maxThreads) {
- this(coreThread, maxThreads, maxThreads);
- }
-
- public StandardThreadExecutor(int coreThread, int maxThreads, long keepAliveTime, TimeUnit unit) {
- this(coreThread, maxThreads, keepAliveTime, unit, maxThreads);
- }
-
- public StandardThreadExecutor(int coreThreads, int maxThreads, int queueCapacity) {
- this(coreThreads, maxThreads, queueCapacity, Executors.defaultThreadFactory());
- }
-
- public StandardThreadExecutor(int coreThreads, int maxThreads, int queueCapacity, ThreadFactory threadFactory) {
- this(coreThreads, maxThreads, DEFAULT_MAX_IDLE_TIME, TimeUnit.MILLISECONDS, queueCapacity, threadFactory);
- }
-
- public StandardThreadExecutor(int coreThreads, int maxThreads, long keepAliveTime, TimeUnit unit, int queueCapacity) {
- this(coreThreads, maxThreads, keepAliveTime, unit, queueCapacity, Executors.defaultThreadFactory());
- }
-
- public StandardThreadExecutor(int coreThreads, int maxThreads, long keepAliveTime, TimeUnit unit,
- int queueCapacity, ThreadFactory threadFactory) {
- this(coreThreads, maxThreads, keepAliveTime, unit, queueCapacity, threadFactory, new AbortPolicy());
- }
-
- public StandardThreadExecutor(int coreThreads, int maxThreads, long keepAliveTime, TimeUnit unit,
- int queueCapacity, ThreadFactory threadFactory, RejectedExecutionHandler handler) {
- super(coreThreads, maxThreads, keepAliveTime, unit, new ExecutorQueue(), threadFactory, handler);
- ((ExecutorQueue) getQueue()).setStandardThreadExecutor(this);
-
- submittedTasksCount = new AtomicInteger(0);
-
- // 最大并发任务限制： 队列buffer数 + 最大线程数
- maxSubmittedTaskCount = queueCapacity + maxThreads;
- }
-
- @Override
- public void execute(Runnable command) {
- int count = submittedTasksCount.incrementAndGet();
-
- // 超过最大的并发任务限制，进行 reject
- // 依赖的LinkedTransferQueue没有长度限制，因此这里进行控制
- if (count > maxSubmittedTaskCount) {
- submittedTasksCount.decrementAndGet();
- getRejectedExecutionHandler().rejectedExecution(command, this);
- }
-
- try {
- super.execute(command);
- } catch (RejectedExecutionException rx) {
- // there could have been contention around the queue
- if (!((ExecutorQueue) getQueue()).force(command)) {
- submittedTasksCount.decrementAndGet();
- getRejectedExecutionHandler().rejectedExecution(command, this);
- }
- rx.printStackTrace();
- }
- }
-
- public int getSubmittedTasksCount() {
- return this.submittedTasksCount.get();
- }
-
-
- protected void afterExecute(Runnable r, Throwable t) {
- submittedTasksCount.decrementAndGet();
- }
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/ssl/SecureSocketKeyStore.java b/src/main/java/com/github/unclecatmyself/common/ssl/SecureSocketKeyStore.java
deleted file mode 100644
index 322f796..0000000
--- a/src/main/java/com/github/unclecatmyself/common/ssl/SecureSocketKeyStore.java
+++ /dev/null
@@ -1,456 +0,0 @@
-package com.github.unclecatmyself.common.ssl;
-
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
-import java.security.KeyStore;
-
-/**
- * A bogus key store which provides all the required information to create an
- * example SSL connection.
- *
- * To generate a bogus key store:
- *
- *
- * keytool -genkey -alias securesocket \ -keysize 2048 -validity 36500 \ -keyalg RSA -dname "CN=securesocket" \ -keypass inc0rrect -storepass mu$tch8ng3 \ -keystore cert.jks
- *
- *
- *
- *
- *
- */
-public class SecureSocketKeyStore {
-
- private static final byte[] CERT_BYTES = { (byte) 254, (byte) 237,
- (byte) 254, (byte) 237, (byte) 0, (byte) 0, (byte) 0, (byte) 2,
- (byte) 0, (byte) 0, (byte) 0, (byte) 1, (byte) 0, (byte) 0,
- (byte) 0, (byte) 1, (byte) 0, (byte) 12, (byte) 115, (byte) 101,
- (byte) 99, (byte) 117, (byte) 114, (byte) 101, (byte) 115,
- (byte) 111, (byte) 99, (byte) 107, (byte) 101, (byte) 116,
- (byte) 0, (byte) 0, (byte) 1, (byte) 69, (byte) 231, (byte) 201,
- (byte) 156, (byte) 140, (byte) 0, (byte) 0, (byte) 5, (byte) 0,
- (byte) 48, (byte) 130, (byte) 4, (byte) 252, (byte) 48, (byte) 14,
- (byte) 6, (byte) 10, (byte) 43, (byte) 6, (byte) 1, (byte) 4,
- (byte) 1, (byte) 42, (byte) 2, (byte) 17, (byte) 1, (byte) 1,
- (byte) 5, (byte) 0, (byte) 4, (byte) 130, (byte) 4, (byte) 232,
- (byte) 221, (byte) 18, (byte) 203, (byte) 171, (byte) 175,
- (byte) 82, (byte) 132, (byte) 227, (byte) 115, (byte) 143,
- (byte) 38, (byte) 191, (byte) 42, (byte) 202, (byte) 130,
- (byte) 171, (byte) 75, (byte) 6, (byte) 161, (byte) 120,
- (byte) 204, (byte) 61, (byte) 106, (byte) 160, (byte) 81, (byte) 9,
- (byte) 204, (byte) 153, (byte) 166, (byte) 38, (byte) 246,
- (byte) 13, (byte) 43, (byte) 19, (byte) 100, (byte) 132, (byte) 45,
- (byte) 90, (byte) 143, (byte) 1, (byte) 231, (byte) 182, (byte) 89,
- (byte) 228, (byte) 183, (byte) 17, (byte) 95, (byte) 129,
- (byte) 229, (byte) 42, (byte) 182, (byte) 126, (byte) 114,
- (byte) 76, (byte) 124, (byte) 123, (byte) 246, (byte) 152,
- (byte) 0, (byte) 141, (byte) 212, (byte) 111, (byte) 52,
- (byte) 243, (byte) 112, (byte) 31, (byte) 117, (byte) 124,
- (byte) 142, (byte) 24, (byte) 59, (byte) 198, (byte) 164,
- (byte) 253, (byte) 21, (byte) 177, (byte) 189, (byte) 74,
- (byte) 218, (byte) 110, (byte) 83, (byte) 154, (byte) 49,
- (byte) 186, (byte) 159, (byte) 173, (byte) 202, (byte) 94,
- (byte) 174, (byte) 183, (byte) 223, (byte) 119, (byte) 109,
- (byte) 110, (byte) 72, (byte) 93, (byte) 208, (byte) 195,
- (byte) 19, (byte) 89, (byte) 33, (byte) 34, (byte) 186, (byte) 12,
- (byte) 86, (byte) 156, (byte) 156, (byte) 210, (byte) 111,
- (byte) 110, (byte) 44, (byte) 106, (byte) 36, (byte) 67,
- (byte) 168, (byte) 7, (byte) 179, (byte) 244, (byte) 53,
- (byte) 134, (byte) 10, (byte) 86, (byte) 179, (byte) 34, (byte) 60,
- (byte) 184, (byte) 179, (byte) 162, (byte) 69, (byte) 24,
- (byte) 168, (byte) 100, (byte) 183, (byte) 206, (byte) 64,
- (byte) 4, (byte) 32, (byte) 66, (byte) 237, (byte) 228, (byte) 92,
- (byte) 6, (byte) 213, (byte) 141, (byte) 147, (byte) 198,
- (byte) 141, (byte) 216, (byte) 41, (byte) 0, (byte) 101, (byte) 65,
- (byte) 41, (byte) 185, (byte) 128, (byte) 229, (byte) 107,
- (byte) 25, (byte) 89, (byte) 148, (byte) 16, (byte) 194,
- (byte) 101, (byte) 100, (byte) 243, (byte) 147, (byte) 77,
- (byte) 230, (byte) 11, (byte) 151, (byte) 99, (byte) 124,
- (byte) 55, (byte) 195, (byte) 185, (byte) 30, (byte) 234,
- (byte) 83, (byte) 61, (byte) 109, (byte) 131, (byte) 156,
- (byte) 244, (byte) 133, (byte) 66, (byte) 39, (byte) 153, (byte) 9,
- (byte) 34, (byte) 218, (byte) 201, (byte) 143, (byte) 190,
- (byte) 127, (byte) 119, (byte) 102, (byte) 6, (byte) 83,
- (byte) 134, (byte) 96, (byte) 170, (byte) 79, (byte) 196,
- (byte) 214, (byte) 47, (byte) 215, (byte) 37, (byte) 250,
- (byte) 64, (byte) 8, (byte) 165, (byte) 203, (byte) 44, (byte) 53,
- (byte) 113, (byte) 147, (byte) 251, (byte) 29, (byte) 26,
- (byte) 38, (byte) 193, (byte) 11, (byte) 223, (byte) 212,
- (byte) 114, (byte) 96, (byte) 162, (byte) 39, (byte) 48,
- (byte) 200, (byte) 172, (byte) 182, (byte) 254, (byte) 180,
- (byte) 198, (byte) 11, (byte) 128, (byte) 75, (byte) 74, (byte) 93,
- (byte) 226, (byte) 157, (byte) 80, (byte) 14, (byte) 9, (byte) 217,
- (byte) 236, (byte) 205, (byte) 153, (byte) 35, (byte) 242,
- (byte) 130, (byte) 140, (byte) 25, (byte) 16, (byte) 156,
- (byte) 247, (byte) 230, (byte) 5, (byte) 247, (byte) 0, (byte) 34,
- (byte) 196, (byte) 15, (byte) 118, (byte) 255, (byte) 185,
- (byte) 199, (byte) 59, (byte) 99, (byte) 27, (byte) 187, (byte) 83,
- (byte) 81, (byte) 12, (byte) 71, (byte) 69, (byte) 127, (byte) 130,
- (byte) 164, (byte) 97, (byte) 195, (byte) 216, (byte) 215,
- (byte) 61, (byte) 29, (byte) 196, (byte) 62, (byte) 160,
- (byte) 188, (byte) 209, (byte) 173, (byte) 230, (byte) 0,
- (byte) 204, (byte) 225, (byte) 1, (byte) 5, (byte) 42, (byte) 223,
- (byte) 232, (byte) 187, (byte) 190, (byte) 67, (byte) 126,
- (byte) 235, (byte) 178, (byte) 218, (byte) 179, (byte) 46,
- (byte) 186, (byte) 156, (byte) 186, (byte) 6, (byte) 191,
- (byte) 68, (byte) 239, (byte) 31, (byte) 16, (byte) 204, (byte) 24,
- (byte) 68, (byte) 164, (byte) 88, (byte) 10, (byte) 174, (byte) 26,
- (byte) 54, (byte) 187, (byte) 149, (byte) 132, (byte) 128,
- (byte) 173, (byte) 165, (byte) 8, (byte) 69, (byte) 96, (byte) 49,
- (byte) 57, (byte) 223, (byte) 110, (byte) 29, (byte) 215,
- (byte) 98, (byte) 42, (byte) 15, (byte) 153, (byte) 228,
- (byte) 216, (byte) 61, (byte) 160, (byte) 230, (byte) 34,
- (byte) 40, (byte) 232, (byte) 136, (byte) 139, (byte) 140,
- (byte) 236, (byte) 251, (byte) 119, (byte) 242, (byte) 199,
- (byte) 167, (byte) 61, (byte) 141, (byte) 89, (byte) 29, (byte) 82,
- (byte) 114, (byte) 229, (byte) 198, (byte) 27, (byte) 133,
- (byte) 87, (byte) 0, (byte) 53, (byte) 69, (byte) 42, (byte) 91,
- (byte) 174, (byte) 82, (byte) 244, (byte) 160, (byte) 82,
- (byte) 142, (byte) 221, (byte) 106, (byte) 151, (byte) 241,
- (byte) 214, (byte) 64, (byte) 14, (byte) 28, (byte) 2, (byte) 3,
- (byte) 145, (byte) 143, (byte) 18, (byte) 165, (byte) 247,
- (byte) 178, (byte) 211, (byte) 16, (byte) 222, (byte) 76,
- (byte) 60, (byte) 119, (byte) 130, (byte) 199, (byte) 230,
- (byte) 229, (byte) 3, (byte) 22, (byte) 100, (byte) 135,
- (byte) 103, (byte) 60, (byte) 181, (byte) 191, (byte) 56,
- (byte) 249, (byte) 181, (byte) 169, (byte) 210, (byte) 25,
- (byte) 152, (byte) 201, (byte) 226, (byte) 119, (byte) 71,
- (byte) 204, (byte) 70, (byte) 220, (byte) 103, (byte) 46,
- (byte) 166, (byte) 125, (byte) 40, (byte) 86, (byte) 208,
- (byte) 114, (byte) 138, (byte) 24, (byte) 27, (byte) 219,
- (byte) 123, (byte) 161, (byte) 52, (byte) 14, (byte) 38,
- (byte) 244, (byte) 112, (byte) 238, (byte) 121, (byte) 90,
- (byte) 34, (byte) 157, (byte) 131, (byte) 53, (byte) 245,
- (byte) 162, (byte) 89, (byte) 188, (byte) 6, (byte) 202,
- (byte) 164, (byte) 130, (byte) 34, (byte) 232, (byte) 74,
- (byte) 45, (byte) 137, (byte) 164, (byte) 200, (byte) 197,
- (byte) 247, (byte) 64, (byte) 110, (byte) 122, (byte) 49,
- (byte) 116, (byte) 137, (byte) 253, (byte) 170, (byte) 232,
- (byte) 120, (byte) 26, (byte) 171, (byte) 228, (byte) 229,
- (byte) 49, (byte) 56, (byte) 56, (byte) 106, (byte) 110, (byte) 12,
- (byte) 109, (byte) 93, (byte) 105, (byte) 241, (byte) 196,
- (byte) 11, (byte) 18, (byte) 89, (byte) 108, (byte) 146,
- (byte) 224, (byte) 161, (byte) 181, (byte) 236, (byte) 74,
- (byte) 128, (byte) 24, (byte) 239, (byte) 22, (byte) 146, (byte) 0,
- (byte) 69, (byte) 182, (byte) 246, (byte) 43, (byte) 59,
- (byte) 208, (byte) 33, (byte) 48, (byte) 81, (byte) 0, (byte) 70,
- (byte) 225, (byte) 222, (byte) 122, (byte) 178, (byte) 138,
- (byte) 12, (byte) 207, (byte) 233, (byte) 164, (byte) 13,
- (byte) 176, (byte) 123, (byte) 95, (byte) 68, (byte) 238,
- (byte) 134, (byte) 66, (byte) 95, (byte) 194, (byte) 192,
- (byte) 225, (byte) 244, (byte) 14, (byte) 78, (byte) 53,
- (byte) 189, (byte) 217, (byte) 229, (byte) 203, (byte) 192,
- (byte) 34, (byte) 38, (byte) 169, (byte) 63, (byte) 239,
- (byte) 128, (byte) 172, (byte) 143, (byte) 75, (byte) 7,
- (byte) 237, (byte) 125, (byte) 179, (byte) 235, (byte) 229,
- (byte) 98, (byte) 8, (byte) 211, (byte) 237, (byte) 116, (byte) 75,
- (byte) 27, (byte) 211, (byte) 131, (byte) 245, (byte) 89,
- (byte) 150, (byte) 35, (byte) 49, (byte) 207, (byte) 113,
- (byte) 237, (byte) 114, (byte) 125, (byte) 134, (byte) 191,
- (byte) 110, (byte) 30, (byte) 119, (byte) 131, (byte) 175,
- (byte) 166, (byte) 201, (byte) 255, (byte) 200, (byte) 1,
- (byte) 126, (byte) 163, (byte) 172, (byte) 52, (byte) 118,
- (byte) 184, (byte) 221, (byte) 165, (byte) 167, (byte) 165,
- (byte) 20, (byte) 135, (byte) 32, (byte) 222, (byte) 188,
- (byte) 250, (byte) 64, (byte) 161, (byte) 67, (byte) 236,
- (byte) 212, (byte) 131, (byte) 44, (byte) 32, (byte) 70, (byte) 0,
- (byte) 24, (byte) 178, (byte) 83, (byte) 155, (byte) 145,
- (byte) 136, (byte) 131, (byte) 120, (byte) 181, (byte) 164,
- (byte) 155, (byte) 172, (byte) 41, (byte) 213, (byte) 164,
- (byte) 98, (byte) 169, (byte) 152, (byte) 184, (byte) 170,
- (byte) 107, (byte) 7, (byte) 21, (byte) 228, (byte) 175,
- (byte) 192, (byte) 238, (byte) 68, (byte) 197, (byte) 119,
- (byte) 228, (byte) 225, (byte) 156, (byte) 235, (byte) 241,
- (byte) 172, (byte) 171, (byte) 236, (byte) 128, (byte) 78,
- (byte) 117, (byte) 152, (byte) 123, (byte) 93, (byte) 156,
- (byte) 57, (byte) 238, (byte) 211, (byte) 188, (byte) 47,
- (byte) 62, (byte) 45, (byte) 127, (byte) 58, (byte) 38, (byte) 29,
- (byte) 131, (byte) 95, (byte) 85, (byte) 149, (byte) 112,
- (byte) 215, (byte) 207, (byte) 41, (byte) 201, (byte) 30,
- (byte) 149, (byte) 73, (byte) 245, (byte) 179, (byte) 176,
- (byte) 246, (byte) 203, (byte) 204, (byte) 252, (byte) 13,
- (byte) 98, (byte) 151, (byte) 93, (byte) 87, (byte) 241,
- (byte) 166, (byte) 46, (byte) 249, (byte) 148, (byte) 49,
- (byte) 141, (byte) 136, (byte) 49, (byte) 77, (byte) 250,
- (byte) 191, (byte) 157, (byte) 90, (byte) 84, (byte) 51,
- (byte) 129, (byte) 133, (byte) 66, (byte) 253, (byte) 99,
- (byte) 243, (byte) 34, (byte) 142, (byte) 197, (byte) 4,
- (byte) 126, (byte) 7, (byte) 217, (byte) 126, (byte) 205,
- (byte) 250, (byte) 141, (byte) 231, (byte) 225, (byte) 203,
- (byte) 171, (byte) 246, (byte) 201, (byte) 48, (byte) 96,
- (byte) 207, (byte) 74, (byte) 253, (byte) 120, (byte) 114,
- (byte) 163, (byte) 192, (byte) 24, (byte) 12, (byte) 10,
- (byte) 210, (byte) 94, (byte) 136, (byte) 152, (byte) 185,
- (byte) 109, (byte) 87, (byte) 35, (byte) 159, (byte) 238,
- (byte) 122, (byte) 200, (byte) 107, (byte) 103, (byte) 243,
- (byte) 250, (byte) 152, (byte) 68, (byte) 66, (byte) 170, (byte) 0,
- (byte) 134, (byte) 229, (byte) 168, (byte) 182, (byte) 30,
- (byte) 89, (byte) 240, (byte) 121, (byte) 106, (byte) 148,
- (byte) 142, (byte) 49, (byte) 242, (byte) 215, (byte) 233,
- (byte) 57, (byte) 120, (byte) 204, (byte) 180, (byte) 239,
- (byte) 199, (byte) 133, (byte) 255, (byte) 71, (byte) 3,
- (byte) 132, (byte) 228, (byte) 110, (byte) 66, (byte) 227,
- (byte) 122, (byte) 82, (byte) 118, (byte) 173, (byte) 218,
- (byte) 54, (byte) 99, (byte) 167, (byte) 154, (byte) 3, (byte) 189,
- (byte) 25, (byte) 123, (byte) 169, (byte) 42, (byte) 184,
- (byte) 59, (byte) 36, (byte) 131, (byte) 206, (byte) 248,
- (byte) 90, (byte) 32, (byte) 183, (byte) 86, (byte) 62, (byte) 149,
- (byte) 107, (byte) 243, (byte) 71, (byte) 197, (byte) 124,
- (byte) 155, (byte) 214, (byte) 91, (byte) 29, (byte) 81, (byte) 28,
- (byte) 115, (byte) 98, (byte) 130, (byte) 184, (byte) 135,
- (byte) 13, (byte) 191, (byte) 147, (byte) 43, (byte) 10,
- (byte) 178, (byte) 99, (byte) 165, (byte) 210, (byte) 87,
- (byte) 87, (byte) 148, (byte) 31, (byte) 198, (byte) 129,
- (byte) 32, (byte) 181, (byte) 3, (byte) 144, (byte) 61, (byte) 5,
- (byte) 166, (byte) 252, (byte) 73, (byte) 205, (byte) 230,
- (byte) 178, (byte) 162, (byte) 46, (byte) 56, (byte) 99, (byte) 77,
- (byte) 97, (byte) 236, (byte) 121, (byte) 157, (byte) 139,
- (byte) 153, (byte) 217, (byte) 171, (byte) 19, (byte) 68,
- (byte) 36, (byte) 14, (byte) 123, (byte) 249, (byte) 101,
- (byte) 127, (byte) 184, (byte) 123, (byte) 7, (byte) 124,
- (byte) 68, (byte) 98, (byte) 34, (byte) 139, (byte) 224,
- (byte) 173, (byte) 246, (byte) 196, (byte) 180, (byte) 70,
- (byte) 207, (byte) 168, (byte) 211, (byte) 255, (byte) 84,
- (byte) 0, (byte) 174, (byte) 11, (byte) 160, (byte) 155,
- (byte) 127, (byte) 228, (byte) 81, (byte) 226, (byte) 115,
- (byte) 142, (byte) 200, (byte) 107, (byte) 4, (byte) 204,
- (byte) 219, (byte) 192, (byte) 189, (byte) 56, (byte) 127,
- (byte) 184, (byte) 187, (byte) 161, (byte) 106, (byte) 62,
- (byte) 225, (byte) 211, (byte) 115, (byte) 30, (byte) 172,
- (byte) 191, (byte) 66, (byte) 25, (byte) 66, (byte) 235,
- (byte) 107, (byte) 41, (byte) 186, (byte) 40, (byte) 239,
- (byte) 173, (byte) 11, (byte) 247, (byte) 89, (byte) 79,
- (byte) 135, (byte) 86, (byte) 73, (byte) 77, (byte) 164, (byte) 34,
- (byte) 109, (byte) 236, (byte) 56, (byte) 198, (byte) 141,
- (byte) 87, (byte) 74, (byte) 172, (byte) 56, (byte) 24, (byte) 150,
- (byte) 233, (byte) 233, (byte) 165, (byte) 122, (byte) 201,
- (byte) 112, (byte) 232, (byte) 23, (byte) 12, (byte) 166,
- (byte) 128, (byte) 114, (byte) 139, (byte) 207, (byte) 233,
- (byte) 47, (byte) 220, (byte) 172, (byte) 175, (byte) 40,
- (byte) 109, (byte) 82, (byte) 142, (byte) 130, (byte) 177,
- (byte) 50, (byte) 127, (byte) 196, (byte) 106, (byte) 172,
- (byte) 178, (byte) 71, (byte) 178, (byte) 204, (byte) 99,
- (byte) 113, (byte) 33, (byte) 189, (byte) 188, (byte) 168,
- (byte) 76, (byte) 92, (byte) 230, (byte) 211, (byte) 239,
- (byte) 75, (byte) 71, (byte) 64, (byte) 197, (byte) 26, (byte) 222,
- (byte) 19, (byte) 213, (byte) 161, (byte) 144, (byte) 20,
- (byte) 126, (byte) 192, (byte) 156, (byte) 15, (byte) 113,
- (byte) 64, (byte) 73, (byte) 7, (byte) 241, (byte) 217, (byte) 127,
- (byte) 171, (byte) 199, (byte) 66, (byte) 32, (byte) 179, (byte) 4,
- (byte) 181, (byte) 93, (byte) 121, (byte) 193, (byte) 10,
- (byte) 169, (byte) 255, (byte) 152, (byte) 199, (byte) 95,
- (byte) 177, (byte) 227, (byte) 135, (byte) 21, (byte) 64,
- (byte) 203, (byte) 9, (byte) 79, (byte) 243, (byte) 114, (byte) 2,
- (byte) 201, (byte) 157, (byte) 180, (byte) 52, (byte) 193,
- (byte) 66, (byte) 34, (byte) 155, (byte) 52, (byte) 35, (byte) 93,
- (byte) 31, (byte) 96, (byte) 77, (byte) 12, (byte) 80, (byte) 195,
- (byte) 96, (byte) 247, (byte) 251, (byte) 237, (byte) 36,
- (byte) 170, (byte) 7, (byte) 3, (byte) 251, (byte) 243, (byte) 47,
- (byte) 180, (byte) 98, (byte) 207, (byte) 176, (byte) 106,
- (byte) 237, (byte) 114, (byte) 91, (byte) 229, (byte) 56,
- (byte) 94, (byte) 154, (byte) 32, (byte) 62, (byte) 240,
- (byte) 132, (byte) 4, (byte) 144, (byte) 227, (byte) 140,
- (byte) 137, (byte) 76, (byte) 15, (byte) 117, (byte) 82,
- (byte) 223, (byte) 168, (byte) 135, (byte) 33, (byte) 91,
- (byte) 173, (byte) 4, (byte) 245, (byte) 192, (byte) 95,
- (byte) 135, (byte) 22, (byte) 138, (byte) 89, (byte) 1, (byte) 14,
- (byte) 230, (byte) 143, (byte) 195, (byte) 93, (byte) 133,
- (byte) 194, (byte) 252, (byte) 188, (byte) 31, (byte) 39,
- (byte) 162, (byte) 59, (byte) 148, (byte) 219, (byte) 213,
- (byte) 179, (byte) 195, (byte) 165, (byte) 67, (byte) 68,
- (byte) 39, (byte) 178, (byte) 143, (byte) 192, (byte) 177,
- (byte) 221, (byte) 236, (byte) 63, (byte) 40, (byte) 205,
- (byte) 26, (byte) 81, (byte) 127, (byte) 5, (byte) 213, (byte) 192,
- (byte) 22, (byte) 147, (byte) 98, (byte) 207, (byte) 153, (byte) 8,
- (byte) 108, (byte) 75, (byte) 182, (byte) 148, (byte) 0,
- (byte) 151, (byte) 15, (byte) 178, (byte) 98, (byte) 145,
- (byte) 255, (byte) 213, (byte) 142, (byte) 63, (byte) 247,
- (byte) 42, (byte) 161, (byte) 246, (byte) 21, (byte) 128,
- (byte) 47, (byte) 248, (byte) 217, (byte) 70, (byte) 195,
- (byte) 151, (byte) 236, (byte) 73, (byte) 153, (byte) 230,
- (byte) 152, (byte) 217, (byte) 12, (byte) 189, (byte) 65,
- (byte) 85, (byte) 189, (byte) 204, (byte) 212, (byte) 161,
- (byte) 210, (byte) 217, (byte) 74, (byte) 75, (byte) 186,
- (byte) 122, (byte) 167, (byte) 149, (byte) 178, (byte) 202,
- (byte) 205, (byte) 246, (byte) 225, (byte) 225, (byte) 190,
- (byte) 56, (byte) 42, (byte) 162, (byte) 215, (byte) 107,
- (byte) 45, (byte) 121, (byte) 235, (byte) 195, (byte) 219,
- (byte) 22, (byte) 0, (byte) 0, (byte) 0, (byte) 1, (byte) 0,
- (byte) 5, (byte) 88, (byte) 46, (byte) 53, (byte) 48, (byte) 57,
- (byte) 0, (byte) 0, (byte) 2, (byte) 211, (byte) 48, (byte) 130,
- (byte) 2, (byte) 207, (byte) 48, (byte) 130, (byte) 1, (byte) 183,
- (byte) 160, (byte) 3, (byte) 2, (byte) 1, (byte) 2, (byte) 2,
- (byte) 4, (byte) 58, (byte) 247, (byte) 71, (byte) 185, (byte) 48,
- (byte) 13, (byte) 6, (byte) 9, (byte) 42, (byte) 134, (byte) 72,
- (byte) 134, (byte) 247, (byte) 13, (byte) 1, (byte) 1, (byte) 11,
- (byte) 5, (byte) 0, (byte) 48, (byte) 23, (byte) 49, (byte) 21,
- (byte) 48, (byte) 19, (byte) 6, (byte) 3, (byte) 85, (byte) 4,
- (byte) 3, (byte) 19, (byte) 12, (byte) 115, (byte) 101, (byte) 99,
- (byte) 117, (byte) 114, (byte) 101, (byte) 115, (byte) 111,
- (byte) 99, (byte) 107, (byte) 101, (byte) 116, (byte) 48,
- (byte) 32, (byte) 23, (byte) 13, (byte) 49, (byte) 52, (byte) 48,
- (byte) 53, (byte) 49, (byte) 48, (byte) 50, (byte) 48, (byte) 49,
- (byte) 56, (byte) 52, (byte) 48, (byte) 90, (byte) 24, (byte) 15,
- (byte) 50, (byte) 49, (byte) 49, (byte) 52, (byte) 48, (byte) 52,
- (byte) 49, (byte) 54, (byte) 50, (byte) 48, (byte) 49, (byte) 56,
- (byte) 52, (byte) 48, (byte) 90, (byte) 48, (byte) 23, (byte) 49,
- (byte) 21, (byte) 48, (byte) 19, (byte) 6, (byte) 3, (byte) 85,
- (byte) 4, (byte) 3, (byte) 19, (byte) 12, (byte) 115, (byte) 101,
- (byte) 99, (byte) 117, (byte) 114, (byte) 101, (byte) 115,
- (byte) 111, (byte) 99, (byte) 107, (byte) 101, (byte) 116,
- (byte) 48, (byte) 130, (byte) 1, (byte) 34, (byte) 48, (byte) 13,
- (byte) 6, (byte) 9, (byte) 42, (byte) 134, (byte) 72, (byte) 134,
- (byte) 247, (byte) 13, (byte) 1, (byte) 1, (byte) 1, (byte) 5,
- (byte) 0, (byte) 3, (byte) 130, (byte) 1, (byte) 15, (byte) 0,
- (byte) 48, (byte) 130, (byte) 1, (byte) 10, (byte) 2, (byte) 130,
- (byte) 1, (byte) 1, (byte) 0, (byte) 153, (byte) 113, (byte) 7,
- (byte) 44, (byte) 219, (byte) 76, (byte) 101, (byte) 226,
- (byte) 138, (byte) 96, (byte) 219, (byte) 60, (byte) 167,
- (byte) 138, (byte) 222, (byte) 6, (byte) 78, (byte) 169, (byte) 64,
- (byte) 188, (byte) 156, (byte) 190, (byte) 119, (byte) 16,
- (byte) 34, (byte) 228, (byte) 250, (byte) 253, (byte) 119,
- (byte) 75, (byte) 240, (byte) 60, (byte) 242, (byte) 52,
- (byte) 137, (byte) 146, (byte) 20, (byte) 130, (byte) 202,
- (byte) 226, (byte) 125, (byte) 19, (byte) 7, (byte) 34, (byte) 8,
- (byte) 61, (byte) 243, (byte) 202, (byte) 225, (byte) 206,
- (byte) 223, (byte) 53, (byte) 74, (byte) 56, (byte) 222, (byte) 47,
- (byte) 99, (byte) 235, (byte) 57, (byte) 73, (byte) 90, (byte) 198,
- (byte) 109, (byte) 104, (byte) 36, (byte) 255, (byte) 124,
- (byte) 57, (byte) 155, (byte) 248, (byte) 120, (byte) 56,
- (byte) 56, (byte) 38, (byte) 41, (byte) 216, (byte) 1, (byte) 216,
- (byte) 216, (byte) 100, (byte) 239, (byte) 79, (byte) 222,
- (byte) 34, (byte) 21, (byte) 182, (byte) 112, (byte) 136,
- (byte) 137, (byte) 16, (byte) 141, (byte) 15, (byte) 83, (byte) 94,
- (byte) 245, (byte) 36, (byte) 203, (byte) 178, (byte) 137,
- (byte) 159, (byte) 86, (byte) 220, (byte) 253, (byte) 112,
- (byte) 200, (byte) 50, (byte) 135, (byte) 215, (byte) 190,
- (byte) 21, (byte) 186, (byte) 84, (byte) 21, (byte) 96, (byte) 126,
- (byte) 253, (byte) 115, (byte) 209, (byte) 241, (byte) 94,
- (byte) 115, (byte) 219, (byte) 0, (byte) 25, (byte) 253,
- (byte) 209, (byte) 182, (byte) 118, (byte) 230, (byte) 10,
- (byte) 50, (byte) 131, (byte) 39, (byte) 249, (byte) 136,
- (byte) 11, (byte) 101, (byte) 192, (byte) 12, (byte) 210,
- (byte) 179, (byte) 237, (byte) 213, (byte) 68, (byte) 101,
- (byte) 58, (byte) 187, (byte) 255, (byte) 240, (byte) 164,
- (byte) 147, (byte) 72, (byte) 148, (byte) 227, (byte) 155,
- (byte) 88, (byte) 250, (byte) 101, (byte) 253, (byte) 87,
- (byte) 140, (byte) 168, (byte) 39, (byte) 163, (byte) 133,
- (byte) 150, (byte) 252, (byte) 226, (byte) 234, (byte) 52,
- (byte) 88, (byte) 40, (byte) 56, (byte) 23, (byte) 105, (byte) 236,
- (byte) 4, (byte) 113, (byte) 98, (byte) 4, (byte) 0, (byte) 117,
- (byte) 59, (byte) 77, (byte) 236, (byte) 135, (byte) 93, (byte) 54,
- (byte) 30, (byte) 6, (byte) 126, (byte) 90, (byte) 15, (byte) 105,
- (byte) 89, (byte) 216, (byte) 154, (byte) 72, (byte) 134,
- (byte) 209, (byte) 74, (byte) 197, (byte) 237, (byte) 51,
- (byte) 37, (byte) 33, (byte) 106, (byte) 50, (byte) 71, (byte) 134,
- (byte) 169, (byte) 173, (byte) 88, (byte) 111, (byte) 217,
- (byte) 117, (byte) 184, (byte) 97, (byte) 1, (byte) 38, (byte) 76,
- (byte) 112, (byte) 170, (byte) 190, (byte) 250, (byte) 96,
- (byte) 17, (byte) 45, (byte) 117, (byte) 183, (byte) 82,
- (byte) 155, (byte) 10, (byte) 53, (byte) 15, (byte) 214, (byte) 36,
- (byte) 134, (byte) 249, (byte) 146, (byte) 98, (byte) 99,
- (byte) 64, (byte) 158, (byte) 99, (byte) 227, (byte) 21, (byte) 92,
- (byte) 98, (byte) 90, (byte) 202, (byte) 214, (byte) 134,
- (byte) 233, (byte) 212, (byte) 149, (byte) 2, (byte) 3, (byte) 1,
- (byte) 0, (byte) 1, (byte) 163, (byte) 33, (byte) 48, (byte) 31,
- (byte) 48, (byte) 29, (byte) 6, (byte) 3, (byte) 85, (byte) 29,
- (byte) 14, (byte) 4, (byte) 22, (byte) 4, (byte) 20, (byte) 115,
- (byte) 110, (byte) 177, (byte) 165, (byte) 41, (byte) 26,
- (byte) 142, (byte) 198, (byte) 221, (byte) 63, (byte) 79,
- (byte) 252, (byte) 219, (byte) 159, (byte) 68, (byte) 102,
- (byte) 76, (byte) 153, (byte) 128, (byte) 164, (byte) 48,
- (byte) 13, (byte) 6, (byte) 9, (byte) 42, (byte) 134, (byte) 72,
- (byte) 134, (byte) 247, (byte) 13, (byte) 1, (byte) 1, (byte) 11,
- (byte) 5, (byte) 0, (byte) 3, (byte) 130, (byte) 1, (byte) 1,
- (byte) 0, (byte) 118, (byte) 55, (byte) 245, (byte) 122,
- (byte) 159, (byte) 155, (byte) 98, (byte) 122, (byte) 229,
- (byte) 186, (byte) 23, (byte) 207, (byte) 109, (byte) 225,
- (byte) 220, (byte) 74, (byte) 51, (byte) 218, (byte) 10,
- (byte) 115, (byte) 137, (byte) 103, (byte) 127, (byte) 28,
- (byte) 30, (byte) 184, (byte) 149, (byte) 249, (byte) 193,
- (byte) 206, (byte) 208, (byte) 181, (byte) 191, (byte) 128,
- (byte) 18, (byte) 208, (byte) 24, (byte) 132, (byte) 147,
- (byte) 184, (byte) 198, (byte) 82, (byte) 204, (byte) 183,
- (byte) 127, (byte) 87, (byte) 234, (byte) 136, (byte) 197,
- (byte) 34, (byte) 232, (byte) 124, (byte) 210, (byte) 2,
- (byte) 192, (byte) 69, (byte) 246, (byte) 25, (byte) 232,
- (byte) 162, (byte) 0, (byte) 157, (byte) 216, (byte) 194,
- (byte) 26, (byte) 207, (byte) 225, (byte) 169, (byte) 59,
- (byte) 246, (byte) 52, (byte) 51, (byte) 150, (byte) 210,
- (byte) 50, (byte) 118, (byte) 58, (byte) 154, (byte) 45,
- (byte) 128, (byte) 138, (byte) 47, (byte) 174, (byte) 83,
- (byte) 117, (byte) 18, (byte) 224, (byte) 9, (byte) 146,
- (byte) 180, (byte) 178, (byte) 22, (byte) 76, (byte) 82,
- (byte) 229, (byte) 16, (byte) 150, (byte) 127, (byte) 13,
- (byte) 122, (byte) 218, (byte) 159, (byte) 195, (byte) 232,
- (byte) 168, (byte) 206, (byte) 105, (byte) 82, (byte) 37,
- (byte) 252, (byte) 186, (byte) 223, (byte) 222, (byte) 7,
- (byte) 106, (byte) 87, (byte) 218, (byte) 89, (byte) 22,
- (byte) 252, (byte) 7, (byte) 177, (byte) 52, (byte) 180, (byte) 9,
- (byte) 16, (byte) 29, (byte) 57, (byte) 192, (byte) 209,
- (byte) 225, (byte) 155, (byte) 16, (byte) 219, (byte) 38,
- (byte) 90, (byte) 174, (byte) 152, (byte) 140, (byte) 252,
- (byte) 114, (byte) 133, (byte) 106, (byte) 24, (byte) 107,
- (byte) 227, (byte) 80, (byte) 166, (byte) 63, (byte) 47, (byte) 16,
- (byte) 15, (byte) 89, (byte) 242, (byte) 19, (byte) 87, (byte) 193,
- (byte) 250, (byte) 222, (byte) 223, (byte) 183, (byte) 61,
- (byte) 91, (byte) 17, (byte) 92, (byte) 35, (byte) 142, (byte) 44,
- (byte) 153, (byte) 135, (byte) 86, (byte) 97, (byte) 70,
- (byte) 205, (byte) 38, (byte) 192, (byte) 18, (byte) 244,
- (byte) 61, (byte) 46, (byte) 21, (byte) 145, (byte) 99, (byte) 72,
- (byte) 142, (byte) 37, (byte) 19, (byte) 219, (byte) 167,
- (byte) 62, (byte) 71, (byte) 197, (byte) 86, (byte) 152,
- (byte) 139, (byte) 122, (byte) 231, (byte) 122, (byte) 206,
- (byte) 42, (byte) 142, (byte) 164, (byte) 237, (byte) 19,
- (byte) 60, (byte) 95, (byte) 239, (byte) 191, (byte) 64,
- (byte) 188, (byte) 94, (byte) 154, (byte) 199, (byte) 252,
- (byte) 62, (byte) 26, (byte) 181, (byte) 194, (byte) 141,
- (byte) 13, (byte) 1, (byte) 112, (byte) 161, (byte) 195,
- (byte) 149, (byte) 116, (byte) 57, (byte) 118, (byte) 114,
- (byte) 248, (byte) 235, (byte) 54, (byte) 229, (byte) 48,
- (byte) 53, (byte) 30, (byte) 145, (byte) 199, (byte) 207,
- (byte) 49, (byte) 175, (byte) 44, (byte) 172, (byte) 120,
- (byte) 254, (byte) 181, (byte) 100, (byte) 113, (byte) 191,
- (byte) 64, (byte) 131, (byte) 125, (byte) 80, (byte) 180,
- (byte) 229, (byte) 109, (byte) 97, (byte) 8, (byte) 166,
- (byte) 155, (byte) 72, (byte) 252, (byte) 84, (byte) 62, (byte) 97,
- (byte) 80, (byte) 26, (byte) 17, (byte) 143, (byte) 96, (byte) 16,
- (byte) 204, (byte) 86, (byte) 61, (byte) 226, (byte) 149 };
-
-
- public static KeyStore getKeyStore()
- {
- KeyStore ks = null;
- try{
- ks = KeyStore.getInstance("JKS");
- ks.load(asInputStream(), getKeyStorePassword());
- }catch(Exception ex){
- throw new RuntimeException("Failed to load SSL key store.", ex);
- }
- return ks;
- }
-
- public static InputStream asInputStream() {
- return new ByteArrayInputStream(CERT_BYTES);
- }
-
- public static char[] getCertificatePassword() {
- return "inc0rrect".toCharArray();
- }
-
- public static char[] getKeyStorePassword() {
- return "mu$tch8ng3".toCharArray();
- }
-
- public static String getCertificatePasswordString() {
- return "inc0rrect";
- }
-
- public static String getKeyStorePasswordString() {
- return "mu$tch8ng3";
- }
-
- private SecureSocketKeyStore() {
-
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/ssl/SecureSocketSslContextFactory.java b/src/main/java/com/github/unclecatmyself/common/ssl/SecureSocketSslContextFactory.java
deleted file mode 100644
index 8425072..0000000
--- a/src/main/java/com/github/unclecatmyself/common/ssl/SecureSocketSslContextFactory.java
+++ /dev/null
@@ -1,89 +0,0 @@
-package com.github.unclecatmyself.common.ssl;
-
-import io.netty.util.internal.SystemPropertyUtil;
-
-import javax.net.ssl.*;
-import java.security.KeyStore;
-import java.security.SecureRandom;
-
-/**
- * Creates a bogus {@link SSLContext}. A client-side context created by this
- * factory accepts any certificate even if it is invalid. A server-side context
- * created by this factory sends a bogus certificate defined in {@link }.
- *
- * You will have to create your context differently in a real world application.
- *
- *
Client Certificate Authentication
- *
- * To enable client certificate authentication:
- *
- * - Enable client authentication on the server side by calling
- * {@link SSLEngine#setNeedClientAuth(boolean)} before creating
- * {@link }.
- * - When initializing an {@link SSLContext} on the client side,
- * specify the {@link KeyManager} that contains the client certificate as
- * the first argument of {@link SSLContext#init(KeyManager[], TrustManager[], SecureRandom)}.
- * - When initializing an {@link SSLContext} on the server side,
- * specify the proper {@link TrustManager} as the second argument of
- * {@link SSLContext#init(KeyManager[], TrustManager[], SecureRandom)}
- * to validate the client certificate.
- *
- */
-public final class SecureSocketSslContextFactory {
-
- private static final String PROTOCOL = "TLS";
- private static final SSLContext SERVER_CONTEXT;
- private static final SSLContext CLIENT_CONTEXT;
-
- static {
- String algorithm = SystemPropertyUtil.get("ssl.KeyManagerFactory.algorithm");
- if (algorithm == null) {
- algorithm = "SunX509";
- }
-
- SSLContext serverContext;
- SSLContext clientContext;
- try {
- //
- //SecureSocketSslContextFactory.class.getResourceAsStream("/securesocket.jks")
- KeyStore ks = KeyStore.getInstance("JKS");
- ks.load(SecureSocketKeyStore.asInputStream(),
- SecureSocketKeyStore.getKeyStorePassword());
-
- // Set up key manager factory to use our key store
- KeyManagerFactory kmf = KeyManagerFactory.getInstance(algorithm);
- kmf.init(ks, SecureSocketKeyStore.getCertificatePassword());
-
- // Initialize the SSLContext to work with our key managers.
- serverContext = SSLContext.getInstance(PROTOCOL);
- serverContext.init(kmf.getKeyManagers(), null, null);
- } catch (Exception e) {
- throw new Error(
- "Failed to initialize the server-side SSLContext", e);
- }
-
- try {
- clientContext = SSLContext.getInstance(PROTOCOL);
- clientContext.init(null, SecureSokcetTrustManagerFactory.getTrustManagers(), null);
- } catch (Exception e) {
- throw new Error(
- "Failed to initialize the client-side SSLContext", e);
- }
-
- SERVER_CONTEXT = serverContext;
- CLIENT_CONTEXT = clientContext;
- }
-
- public static SSLContext getServerContext() {
- return SERVER_CONTEXT;
- }
-
- public static SSLContext getClientContext() {
- return CLIENT_CONTEXT;
- }
-
- private SecureSocketSslContextFactory() {
- // Unused
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/ssl/SecureSokcetTrustManagerFactory.java b/src/main/java/com/github/unclecatmyself/common/ssl/SecureSokcetTrustManagerFactory.java
deleted file mode 100644
index c4d8975..0000000
--- a/src/main/java/com/github/unclecatmyself/common/ssl/SecureSokcetTrustManagerFactory.java
+++ /dev/null
@@ -1,63 +0,0 @@
-package com.github.unclecatmyself.common.ssl;
-
-import javax.net.ssl.ManagerFactoryParameters;
-import javax.net.ssl.TrustManager;
-import javax.net.ssl.TrustManagerFactorySpi;
-import javax.net.ssl.X509TrustManager;
-import java.security.InvalidAlgorithmParameterException;
-import java.security.KeyStore;
-import java.security.KeyStoreException;
-import java.security.cert.X509Certificate;
-
-/**
- * Bogus {@link TrustManagerFactorySpi} which accepts any certificate
- * even if it is invalid.
- */
-public class SecureSokcetTrustManagerFactory extends TrustManagerFactorySpi {
-
- private static final TrustManager DUMMY_TRUST_MANAGER = new X509TrustManager() {
- @Override
- public X509Certificate[] getAcceptedIssuers() {
- return new X509Certificate[0];
- }
-
- @Override
- public void checkClientTrusted(X509Certificate[] chain, String authType) {
- // Always trust - it is an example.
- // You should do something in the real world.
- // You will reach here only if you enabled client certificate auth,
- // as described in SecureChatSslContextFactory.
- System.err.println(
- "UNKNOWN CLIENT CERTIFICATE: " + chain[0].getSubjectDN());
- }
-
- @Override
- public void checkServerTrusted(X509Certificate[] chain, String authType) {
- // Always trust - it is an example.
- // You should do something in the real world.
- System.err.println(
- "UNKNOWN SERVER CERTIFICATE: 222 " + chain[0].getSubjectDN());
- }
- };
-
- public static TrustManager[] getTrustManagers() {
- return new TrustManager[] { DUMMY_TRUST_MANAGER };
- }
-
- @Override
- protected TrustManager[] engineGetTrustManagers() {
- return getTrustManagers();
- }
-
- @Override
- protected void engineInit(KeyStore keystore) throws KeyStoreException {
- // Unused
- }
-
- @Override
- protected void engineInit(ManagerFactoryParameters managerFactoryParameters)
- throws InvalidAlgorithmParameterException {
- // Unused
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/ssl/StreamReader.java b/src/main/java/com/github/unclecatmyself/common/ssl/StreamReader.java
deleted file mode 100644
index 1f75cb5..0000000
--- a/src/main/java/com/github/unclecatmyself/common/ssl/StreamReader.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package com.github.unclecatmyself.common.ssl;
-
-import java.io.InputStream;
-
-public class StreamReader {
-
- public String toByteArray(InputStream fin)
- {
- int i = -1;
- StringBuilder buf = new StringBuilder();
- try{
- while((i=fin.read())!=-1){
- if(buf.length()>0) buf.append(",");
- buf.append("(byte)");
- buf.append(i);
- }
-
- }catch(Throwable e){
- ;
- }
-
- return buf.toString();
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/ssl/X509CertTool.java b/src/main/java/com/github/unclecatmyself/common/ssl/X509CertTool.java
deleted file mode 100644
index 304e014..0000000
--- a/src/main/java/com/github/unclecatmyself/common/ssl/X509CertTool.java
+++ /dev/null
@@ -1,69 +0,0 @@
-package com.github.unclecatmyself.common.ssl;
-
-
-
-
-import sun.security.x509.*;
-
-import java.io.IOException;
-import java.math.BigInteger;
-import java.security.GeneralSecurityException;
-import java.security.KeyPair;
-import java.security.PrivateKey;
-import java.security.SecureRandom;
-import java.security.cert.X509Certificate;
-import java.util.Date;
-
-
-/**
- * This class would require rt.jar in the class path in order to
- * generated it alternative is using keytool.
- */
-public class X509CertTool {
-
- /**
- * Create a self-signed X.509 Certificate
- * @param dn the X.509 Distinguished Name, eg "CN=Test, L=London, C=GB"
- * @param pair the KeyPair
- * @param days how many days from now the Certificate is valid for
- * @param algorithm the signing algorithm, eg "SHA1withRSA"
- */
- @SuppressWarnings("restriction")
- X509Certificate generateCertificate(String dn, KeyPair pair, int days,
- String algorithm) throws GeneralSecurityException, IOException {
- PrivateKey privkey = pair.getPrivate();
- X509CertInfo info = new X509CertInfo();
- Date from = new Date();
- Date to = new Date(from.getTime() + days * 86400000l);
- CertificateValidity interval = new CertificateValidity(from, to);
- BigInteger sn = new BigInteger(64, new SecureRandom());
- X500Name owner = new X500Name(dn);
-
- info.set(X509CertInfo.VALIDITY, interval);
- info.set(X509CertInfo.SERIAL_NUMBER, new CertificateSerialNumber(sn));
- info.set(X509CertInfo.SUBJECT, new CertificateSubjectName(owner));
- info.set(X509CertInfo.ISSUER, new CertificateIssuerName(owner));
- info.set(X509CertInfo.KEY, new CertificateX509Key(pair.getPublic()));
- info.set(X509CertInfo.VERSION, new CertificateVersion(
- CertificateVersion.V3));
- AlgorithmId algo = new AlgorithmId(AlgorithmId.md5WithRSAEncryption_oid);
- info.set(X509CertInfo.ALGORITHM_ID, new CertificateAlgorithmId(algo));
-
- // Sign the cert to identify the algorithm that's used.
- X509CertImpl cert = new X509CertImpl(info);
- cert.sign(privkey, algorithm);
-
- // Update the algorith, and resign.
- algo = (AlgorithmId) cert.get(X509CertImpl.SIG_ALG);
- info.set(CertificateAlgorithmId.NAME + "."
- + CertificateAlgorithmId.ALGORITHM, algo);
- cert = new X509CertImpl(info);
- cert.sign(privkey, algorithm);
- return cert;
- }
-
- public static void main(String[] args) {
-
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/utils/HttpUtil.java b/src/main/java/com/github/unclecatmyself/common/utils/HttpUtil.java
deleted file mode 100644
index f9fd8e9..0000000
--- a/src/main/java/com/github/unclecatmyself/common/utils/HttpUtil.java
+++ /dev/null
@@ -1,63 +0,0 @@
-package com.github.unclecatmyself.common.utils;
-
-import com.alibaba.fastjson.JSONObject;
-import com.github.unclecatmyself.common.bean.vo.SendServerVO;
-import com.github.unclecatmyself.common.constant.Constans;
-import com.github.unclecatmyself.common.constant.HttpConstant;
-import io.netty.handler.codec.http.FullHttpRequest;
-import io.netty.handler.codec.http.HttpMethod;
-import io.netty.util.CharsetUtil;
-
-import java.io.*;
-import java.net.HttpURLConnection;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.util.Map;
-
-/**
- * HTTP接口处理方法
- * Create by UncleCatMySelf in 22:43 2018\12\30 0030
- */
-public class HttpUtil {
-
- public static String checkType(FullHttpRequest msg){
- msg.retain();
- String url = msg.uri();
- System.out.println(url);
- HttpMethod method = msg.method();
- String meName = method.name();
- if (url.equals(HttpConstant.URI_GETSIZE) && meName.equals(HttpConstant.GET)){
- return HttpConstant.GETSIZE;
- }else if (url.equals(HttpConstant.URI_SENDFROMSERVER) && meName.equals(HttpConstant.POST)){
- return HttpConstant.SENDFROMSERVER;
- }else if (url.equals(HttpConstant.URI_GETLIST) && meName.equals(HttpConstant.GET)){
- return HttpConstant.GETLIST;
- }else if (url.equals(HttpConstant.URI_SENDINCHAT) && meName.equals(HttpConstant.POST)){
- return HttpConstant.SENDINCHAT;
- }else {
- return HttpConstant.NOTFINDURI;
- }
- }
-
- public static SendServerVO getToken(FullHttpRequest msg) throws UnsupportedEncodingException {
- msg.retain();
- SendServerVO sendServerVO = new SendServerVO();
- String content = msg.content().toString(CharsetUtil.UTF_8);
- String[] stars = content.split("&");
- for (int i=0,len=stars.length;i maps){
- InChatMessage message = new InChatMessage();
- if (maps.containsKey(Constans.TOKEN)){
- message.setToken((String) maps.get(Constans.TOKEN));
- }
- if (maps.containsKey(Constans.TIME)){
- message.setTime((Date) maps.get(Constans.TIME));
- }
- if (maps.containsKey(Constans.VALUE)){
- message.setValue((String)maps.get(Constans.VALUE));
- }
- if (maps.containsKey(Constans.TYPE)){
- message.setType((String)maps.get(Constans.TYPE));
- }
- if (maps.containsKey(Constans.ONE)){
- message.setOne((String)maps.get(Constans.ONE));
- }
- if (maps.containsKey(Constans.GROUPID)){
- message.setGroudId((String)maps.get(Constans.GROUPID));
- }
- if (maps.containsKey(Constans.ON_ONLINE)){
- message.setOnline((String)maps.get(Constans.ON_ONLINE));
- }
- if (maps.containsKey(Constans.ONLINE_GROUP)){
- message.setOnlineGroup((ArrayList)maps.get(Constans.ONLINE_GROUP));
- }
- return message;
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/utils/RedisUtil.java b/src/main/java/com/github/unclecatmyself/common/utils/RedisUtil.java
deleted file mode 100644
index d659d91..0000000
--- a/src/main/java/com/github/unclecatmyself/common/utils/RedisUtil.java
+++ /dev/null
@@ -1,59 +0,0 @@
-package com.github.unclecatmyself.common.utils;
-
-import java.security.MessageDigest;
-
-/**
- * Create by UncleCatMySelf in 15:13 2019\1\5 0005
- */
-public class RedisUtil {
-
- private static final String STAL = "InChat";
-
- public static String string2MD5(String inStr) {
- MessageDigest md5 = null;
- try {
- md5 = MessageDigest.getInstance("MD5");
- } catch (Exception e) {
- System.out.println(e.toString());
- e.printStackTrace();
- return "";
- }
- char[] charArray = inStr.toCharArray();
- byte[] byteArray = new byte[charArray.length];
- for (int i = 0; i < charArray.length; i++) byteArray[i] = (byte) charArray[i];
- byte[] md5Bytes = md5.digest(byteArray);
- StringBuffer hexValue = new StringBuffer();
- for (int i = 0; i < md5Bytes.length; i++) {
- int val = ((int) md5Bytes[i]) & 0xff;
- if (val < 16)
- hexValue.append("0");
- hexValue.append(Integer.toHexString(val));
- }
- return hexValue.toString();
- }
-
- public static String convertMD5(String address,String token){
- String inStr = address+"&"+token+"%"+STAL;
- char[] a = inStr.toCharArray();
- for (int i = 0; i < a.length; i++){
- a[i] = (char) (a[i] ^ 't');
- }
- String s = new String(a);
- return s;
- }
-
- public static String convertMD5(String inStr){
- char[] a = inStr.toCharArray();
- for (int i = 0; i < a.length; i++){
- a[i] = (char) (a[i] ^ 't');
- }
- String s = new String(a);
- return s;
- }
-
- public static String getAddress(String s) {
- String[] stars = s.split("&");
- return stars[0];
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/utils/RemotingUtil.java b/src/main/java/com/github/unclecatmyself/common/utils/RemotingUtil.java
deleted file mode 100644
index c2c72b7..0000000
--- a/src/main/java/com/github/unclecatmyself/common/utils/RemotingUtil.java
+++ /dev/null
@@ -1,187 +0,0 @@
-package com.github.unclecatmyself.common.utils;
-
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-import java.lang.reflect.Method;
-import java.net.*;
-import java.nio.channels.Selector;
-import java.nio.channels.SocketChannel;
-import java.nio.channels.spi.SelectorProvider;
-import java.util.ArrayList;
-import java.util.Enumeration;
-
-public class RemotingUtil {
-
- public static final String OS_NAME = System.getProperty("os.name");
-
- private static final Logger log = LoggerFactory.getLogger(RemotingUtil.class);
- private static boolean isLinuxPlatform = false;
- private static boolean isWindowsPlatform = false;
-
- static {
- if (OS_NAME != null && OS_NAME.toLowerCase().contains("linux")) {
- isLinuxPlatform = true;
- }
-
- if (OS_NAME != null && OS_NAME.toLowerCase().contains("windows")) {
- isWindowsPlatform = true;
- }
- }
-
- public static boolean isWindowsPlatform() {
- return isWindowsPlatform;
- }
-
- public static Selector openSelector() throws IOException {
- Selector result = null;
-
- if (isLinuxPlatform()) {
- try {
- final Class providerClazz = Class.forName("sun.nio.ch.EPollSelectorProvider");
- if (providerClazz != null) {
- try {
- final Method method = providerClazz.getMethod("provider");
- if (method != null) {
- final SelectorProvider selectorProvider = (SelectorProvider) method.invoke(null);
- if (selectorProvider != null) {
- result = selectorProvider.openSelector();
- }
- }
- } catch (final Exception e) {
- log.warn("Open ePoll Selector for linux platform exception", e);
- }
- }
- } catch (final Exception e) {
- // ignore
- }
- }
-
- if (result == null) {
- result = Selector.open();
- }
-
- return result;
- }
-
- public static boolean isLinuxPlatform() {
- return isLinuxPlatform;
- }
-
- public static String getLocalAddress() {
- try {
- // Traversal Network interface to get the first non-loopback and non-private address
- Enumeration enumeration = NetworkInterface.getNetworkInterfaces();
- ArrayList ipv4Result = new ArrayList();
- ArrayList ipv6Result = new ArrayList();
- while (enumeration.hasMoreElements()) {
- final NetworkInterface networkInterface = enumeration.nextElement();
- final Enumeration en = networkInterface.getInetAddresses();
- while (en.hasMoreElements()) {
- final InetAddress address = en.nextElement();
- if (!address.isLoopbackAddress()) {
- if (address instanceof Inet6Address) {
- ipv6Result.add(normalizeHostAddress(address));
- } else {
- ipv4Result.add(normalizeHostAddress(address));
- }
- }
- }
- }
-
- // prefer ipv4
- if (!ipv4Result.isEmpty()) {
- for (String ip : ipv4Result) {
- if (ip.startsWith("127.0") || ip.startsWith("192.168")) {
- continue;
- }
-
- return ip;
- }
-
- return ipv4Result.get(ipv4Result.size() - 1);
- } else if (!ipv6Result.isEmpty()) {
- return ipv6Result.get(0);
- }
- //If failed to find,fall back to localhost
- final InetAddress localHost = InetAddress.getLocalHost();
- return normalizeHostAddress(localHost);
- } catch (Exception e) {
- log.error("Failed to obtain local address", e);
- }
-
- return null;
- }
-
- public static String normalizeHostAddress(final InetAddress localHost) {
- if (localHost instanceof Inet6Address) {
- return "[" + localHost.getHostAddress() + "]";
- } else {
- return localHost.getHostAddress();
- }
- }
-
- public static SocketAddress string2SocketAddress(final String addr) {
- String[] s = addr.split(":");
- InetSocketAddress isa = new InetSocketAddress(s[0], Integer.parseInt(s[1]));
- return isa;
- }
-
- public static String socketAddress2String(final SocketAddress addr) {
- StringBuilder sb = new StringBuilder();
- InetSocketAddress inetSocketAddress = (InetSocketAddress) addr;
- sb.append(inetSocketAddress.getAddress().getHostAddress());
- sb.append(":");
- sb.append(inetSocketAddress.getPort());
- return sb.toString();
- }
-
- public static SocketChannel connect(SocketAddress remote) {
- return connect(remote, 1000 * 5);
- }
-
- public static SocketChannel connect(SocketAddress remote, final int timeoutMillis) {
- SocketChannel sc = null;
- try {
- sc = SocketChannel.open();
- sc.configureBlocking(true);
- sc.socket().setSoLinger(false, -1);
- sc.socket().setTcpNoDelay(true);
- sc.socket().setReceiveBufferSize(1024 * 64);
- sc.socket().setSendBufferSize(1024 * 64);
- sc.socket().connect(remote, timeoutMillis);
- sc.configureBlocking(false);
- return sc;
- } catch (Exception e) {
- if (sc != null) {
- try {
- sc.close();
- } catch (IOException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- return null;
- }
-
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/common/utils/SslUtil.java b/src/main/java/com/github/unclecatmyself/common/utils/SslUtil.java
deleted file mode 100644
index 5796806..0000000
--- a/src/main/java/com/github/unclecatmyself/common/utils/SslUtil.java
+++ /dev/null
@@ -1,35 +0,0 @@
-package com.github.unclecatmyself.common.utils;
-
-import com.github.unclecatmyself.common.constant.UtilConstant;
-
-import javax.net.ssl.KeyManagerFactory;
-import javax.net.ssl.SSLContext;
-import java.io.FileInputStream;
-import java.io.InputStream;
-import java.security.KeyStore;
-
-/**
- * Created by MySelf on 2019/1/8.
- */
-public class SslUtil {
-
- private static volatile SSLContext sslContext = null;
-
- public static SSLContext createSSLContext(String type ,String path ,String password) throws Exception {
- if(null == sslContext){
- synchronized (SslUtil.class) {
- if(null == sslContext){
- KeyStore ks = KeyStore.getInstance(type); /// "JKS"
- InputStream ksInputStream = new FileInputStream(UtilConstant.PATH_PREFIX+path); /// 证书存放地址
- ks.load(ksInputStream, password.toCharArray());
- KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
- kmf.init(ks, password.toCharArray());
- sslContext = SSLContext.getInstance(UtilConstant.INSTANT);
- sslContext.init(kmf.getKeyManagers(), null, null);
- }
- }
- }
- return sslContext;
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java b/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java
new file mode 100644
index 0000000..6465102
--- /dev/null
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java
@@ -0,0 +1,60 @@
+package com.github.unclecatmyself.demo1;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.ssl.SslContext;
+import io.netty.handler.ssl.SslContextBuilder;
+import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
+
+/**
+ * @ClassName EchoClient
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/17 17:56
+ * @Version 1.0
+ **/
+public final class EchoClient {
+
+ static final boolean SSL = System.getProperty("ssl") != null;
+ static final String HOST = System.getProperty("host", "127.0.0.1");
+ static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
+ static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
+
+ public static void main(String[] args) throws Exception {
+ final SslContext sslCtx;
+ if (SSL){
+ sslCtx = SslContextBuilder.forClient()
+ .trustManager(InsecureTrustManagerFactory.INSTANCE).build();
+ }else {
+ sslCtx = null;
+ }
+
+ EventLoopGroup group = new NioEventLoopGroup();
+ try {
+ Bootstrap b = new Bootstrap();
+ b.group(group)
+ .channel(NioSocketChannel.class)
+ .option(ChannelOption.TCP_NODELAY,true)
+ .handler(new ChannelInitializer() {
+ @Override
+ protected void initChannel(SocketChannel sc) throws Exception {
+ ChannelPipeline p = sc.pipeline();
+ if (sslCtx != null){
+ p.addLast(sslCtx.newHandler(sc.alloc(),HOST,PORT));
+ }
+ p.addLast(new EchoClientHandler());
+ }
+ });
+
+ ChannelFuture f = b.connect(HOST,PORT).sync();
+
+ f.channel().closeFuture().sync();
+ }finally {
+ group.shutdownGracefully();
+ }
+ }
+
+}
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java b/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java
new file mode 100644
index 0000000..db3e6fa
--- /dev/null
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java
@@ -0,0 +1,46 @@
+package com.github.unclecatmyself.demo1;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+/**
+ * @ClassName EchoClientHandler
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/17 18:06
+ * @Version 1.0
+ **/
+public class EchoClientHandler extends ChannelInboundHandlerAdapter {
+
+ private final ByteBuf firstMessage;
+
+ public EchoClientHandler(){
+ firstMessage = Unpooled.buffer(EchoClient.SIZE);
+ for (int i = 0; i < firstMessage.capacity(); i++){
+ firstMessage.writeByte((byte)i);
+ }
+ }
+
+ @Override
+ public void channelActive(ChannelHandlerContext ctx) throws Exception {
+ ctx.writeAndFlush(firstMessage);
+ }
+
+ @Override
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+ ctx.write(msg);
+ }
+
+ @Override
+ public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ ctx.flush();
+ }
+
+ @Override
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ cause.printStackTrace();
+ ctx.close();
+ }
+}
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java b/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
new file mode 100644
index 0000000..e1cfce4
--- /dev/null
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
@@ -0,0 +1,68 @@
+package com.github.unclecatmyself.demo1;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+import io.netty.handler.ssl.SslContext;
+import io.netty.handler.ssl.SslContextBuilder;
+import io.netty.handler.ssl.util.SelfSignedCertificate;
+
+/**
+ * @ClassName EchoServer
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/17 18:15
+ * @Version 1.0
+ **/
+public final class EchoServer {
+
+ static final boolean SSL = System.getProperty("ssl") != null;
+ static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
+
+ public static void main(String[] args) throws Exception {
+ final SslContext sslCtx;
+ if (SSL){
+ SelfSignedCertificate ssc = new SelfSignedCertificate();
+ sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
+ }else{
+ sslCtx = null;
+ }
+
+ EventLoopGroup bossGroup = new NioEventLoopGroup(1);
+ EventLoopGroup workerGroup = new NioEventLoopGroup();
+ final EchoServerHandler serverHandler = new EchoServerHandler();
+ try {
+ ServerBootstrap b = new ServerBootstrap();
+ b.group(bossGroup,workerGroup)
+ .channel(NioServerSocketChannel.class)
+ .option(ChannelOption.SO_BACKLOG,100)
+ .handler(new LoggingHandler(LogLevel.INFO))
+ .childHandler(new ChannelInitializer() {
+ @Override
+ protected void initChannel(SocketChannel ch) throws Exception {
+ ChannelPipeline p = ch.pipeline();
+ if (sslCtx != null){
+ p.addLast(sslCtx.newHandler(ch.alloc()));
+ }
+ p.addLast(serverHandler);
+ }
+ })
+ ;
+
+ ChannelFuture f = b.bind(PORT).sync();
+
+ f.channel().closeFuture().sync();
+
+ }finally {
+ bossGroup.shutdownGracefully();
+ workerGroup.shutdownGracefully();
+ }
+
+ }
+
+}
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoServerHandler.java b/src/main/java/com/github/unclecatmyself/demo1/EchoServerHandler.java
new file mode 100644
index 0000000..96d3bb6
--- /dev/null
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoServerHandler.java
@@ -0,0 +1,31 @@
+package com.github.unclecatmyself.demo1;
+
+import io.netty.channel.ChannelHandler;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+/**
+ * @ClassName EchoServerHandler
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/17 18:14
+ * @Version 1.0
+ **/
+@ChannelHandler.Sharable
+public class EchoServerHandler extends ChannelInboundHandlerAdapter {
+ @Override
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+ ctx.write(msg);
+ }
+
+ @Override
+ public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ ctx.flush();
+ }
+
+ @Override
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ cause.printStackTrace();
+ ctx.close();
+ }
+}
diff --git a/src/main/java/com/github/unclecatmyself/task/DataAsynchronousTask.java b/src/main/java/com/github/unclecatmyself/task/DataAsynchronousTask.java
deleted file mode 100644
index 7714d5e..0000000
--- a/src/main/java/com/github/unclecatmyself/task/DataAsynchronousTask.java
+++ /dev/null
@@ -1,52 +0,0 @@
-package com.github.unclecatmyself.task;
-
-import com.github.unclecatmyself.bootstrap.data.InChatToDataBaseService;
-import com.github.unclecatmyself.common.constant.LogConstant;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.Map;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.FutureTask;
-
-/**
- * 数据异步转移方法
- * Created by MySelf on 2018/12/3.
- */
-public class DataAsynchronousTask {
-
- private final Logger log = LoggerFactory.getLogger(DataAsynchronousTask.class);
-
- /** 用户读数据接口伪实现 */
- private final InChatToDataBaseService inChatToDataBaseService;
-
-
- public DataAsynchronousTask(InChatToDataBaseService inChatToDataBaseService){
- this.inChatToDataBaseService = inChatToDataBaseService;
- }
-
- /**
- * 将Netty数据消息借助这个方法已新线程发送给用户实现读方法
- * @param maps {@link Map} 传递消息
- */
- public void writeData(Map maps){
- Boolean result = false;
- ExecutorService service = Executors.newCachedThreadPool();
- final FutureTask future = new FutureTask(new DataCallable(inChatToDataBaseService,maps));
- service.execute(future);
- try {
- result = future.get();
- } catch (InterruptedException e) {
- e.printStackTrace();
- log.error(LogConstant.DATAASYNCHRONOUSTASK_01);
- } catch (ExecutionException e) {
- log.error(LogConstant.DATAASYNCHRONOUSTASK_02);
- }
- if (!result){
- log.error(LogConstant.DATAASYNCHRONOUSTASK_03);
- }
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/task/DataCallable.java b/src/main/java/com/github/unclecatmyself/task/DataCallable.java
deleted file mode 100644
index 902b71b..0000000
--- a/src/main/java/com/github/unclecatmyself/task/DataCallable.java
+++ /dev/null
@@ -1,30 +0,0 @@
-package com.github.unclecatmyself.task;
-
-import com.github.unclecatmyself.bootstrap.data.InChatToDataBaseService;
-import com.github.unclecatmyself.common.utils.MessageChangeUtil;
-
-import java.util.Map;
-import java.util.concurrent.Callable;
-
-/**
- * 获取结果的异步线程任务
- * Create by UncleCatMySelf in 11:25 2018\12\30 0030
- */
-public class DataCallable implements Callable{
-
- /** 用户读数据接口伪实现 */
- private final InChatToDataBaseService inChatToDataBaseService;
- /** 消息数据 */
- private final Map maps;
-
- DataCallable(InChatToDataBaseService inChatToDataBaseService,Map maps) {
- this.inChatToDataBaseService = inChatToDataBaseService;
- this.maps = maps;
- }
-
- @Override
- public Boolean call() throws Exception {
- inChatToDataBaseService.writeMessage(MessageChangeUtil.Change(maps));
- return true;
- }
-}
diff --git a/src/main/java/com/github/unclecatmyself/users/DataBaseServiceImpl.java b/src/main/java/com/github/unclecatmyself/users/DataBaseServiceImpl.java
deleted file mode 100644
index 331c91b..0000000
--- a/src/main/java/com/github/unclecatmyself/users/DataBaseServiceImpl.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package com.github.unclecatmyself.users;
-
-import com.github.unclecatmyself.bootstrap.data.InChatToDataBaseService;
-import com.github.unclecatmyself.common.bean.InChatMessage;
-
-/**
- * Created by MySelf on 2019/1/3.
- */
-public class DataBaseServiceImpl implements InChatToDataBaseService {
- //获取消息
- public Boolean writeMessage(InChatMessage inChatMessage) {
- System.out.println(inChatMessage.toString());
- return true;
- }
-}
diff --git a/src/main/java/com/github/unclecatmyself/users/FromServerServiceImpl.java b/src/main/java/com/github/unclecatmyself/users/FromServerServiceImpl.java
deleted file mode 100644
index d86ae40..0000000
--- a/src/main/java/com/github/unclecatmyself/users/FromServerServiceImpl.java
+++ /dev/null
@@ -1,49 +0,0 @@
-package com.github.unclecatmyself.users;
-
-import com.github.unclecatmyself.bootstrap.channel.http.FromServerService;
-
-/**
- * Created by MySelf on 2019/1/3.
- */
-public enum FromServerServiceImpl implements FromServerService {
-
- TYPE1(1,"【系统通知】您的账号存在异常，请注意安全保密信息。"),
- TYPE2(2,"【系统通知】恭喜您连续登录超过5天，奖励5积分。");
-
- private Integer code;
-
- private String message;
-
- FromServerServiceImpl(Integer code, String message){
- this.code = code;
- this.message = message;
- }
-
- public Integer getCode() {
- return code;
- }
-
- public String findByCode(Object code) {
- Integer codes = (Integer)code;
- for (FromServerServiceImpl item: FromServerServiceImpl.values()) {
- if (item.code == codes){
- return item.message;
- }
- }
- return null;
- }
-
- public void setCode(Integer code) {
- this.code = code;
- }
-
- public String getMessage() {
- return message;
- }
-
- public void setMessage(String message) {
- this.message = message;
- }
-
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/users/MyInit.java b/src/main/java/com/github/unclecatmyself/users/MyInit.java
deleted file mode 100644
index 5e47fac..0000000
--- a/src/main/java/com/github/unclecatmyself/users/MyInit.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package com.github.unclecatmyself.users;
-
-import com.github.unclecatmyself.common.bean.InitNetty;
-
-/**
- * Created by MySelf on 2019/1/3.
- */
-public class MyInit extends InitNetty {
-
- @Override
- public int getWebport() {
- return 8090;
- }
-
- @Override
- public Boolean getDistributed() {
- return false;
- }
-
- @Override
- public boolean isSsl() {
- return false;
- }
-
-}
diff --git a/src/main/java/com/github/unclecatmyself/users/VerifyServiceImpl.java b/src/main/java/com/github/unclecatmyself/users/VerifyServiceImpl.java
deleted file mode 100644
index 8bcbb5d..0000000
--- a/src/main/java/com/github/unclecatmyself/users/VerifyServiceImpl.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package com.github.unclecatmyself.users;
-
-import com.alibaba.fastjson.JSONArray;
-import com.github.unclecatmyself.bootstrap.verify.InChatVerifyService;
-
-/**
- * Created by MySelf on 2019/1/3.
- */
-public class VerifyServiceImpl implements InChatVerifyService {
-
-
- public boolean verifyToken(String token) {
- return true;
- }
-
-
- public JSONArray getArrayByGroupId(String groupId) {
- JSONArray jsonArray = JSONArray.parseArray("[\"1111\",\"2222\",\"3333\"]");
- return jsonArray;
- }
-}
diff --git a/src/main/resources/log4j.properties b/src/main/resources/log4j.properties
deleted file mode 100644
index 30185a7..0000000
--- a/src/main/resources/log4j.properties
+++ /dev/null
@@ -1,17 +0,0 @@
-log4j.rootLogger=debug, stdout
-
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-
-log4j.appender.stdout.layout.ConversionPattern=%5p - %m%n
-
-#log4j.appender.R=org.apache.log4j.RollingFileAppender
-#log4j.appender.R.File=firestorm.log
-
-log4j.appender.R.MaxFileSize=100KB
-log4j.appender.R.MaxBackupIndex=1
-
-log4j.appender.R.layout=org.apache.log4j.PatternLayout
-log4j.appender.R.layout.ConversionPattern=%p %t %c - %m%n
-
-log4j.logger.com.codefutures=DEBUG
\ No newline at end of file
diff --git a/src/test/java/com/github/unclecatmyself/common/utils/RedisUtilTests.java b/src/test/java/com/github/unclecatmyself/common/utils/RedisUtilTests.java
deleted file mode 100644
index 21cf2db..0000000
--- a/src/test/java/com/github/unclecatmyself/common/utils/RedisUtilTests.java
+++ /dev/null
@@ -1,51 +0,0 @@
-package com.github.unclecatmyself.common.utils;
-
-import org.junit.Assert;
-import org.junit.Test;
-
-public class RedisUtilTests {
-
- @Test
- public void testString2MD5() {
- Assert.assertEquals("d41d8cd98f00b204e9800998ecf8427e",
- RedisUtil.string2MD5(""));
- Assert.assertEquals("202cb962ac59075b964b07152d234b70",
- RedisUtil.string2MD5("123"));
- Assert.assertEquals("acbd18db4cc2f85cedef654fccc4a4d8",
- RedisUtil.string2MD5("foo"));
- Assert.assertEquals("8a6551f0a3e52a89dbf095f3ea1fe59f",
- RedisUtil.string2MD5("£$%^&*"));
- }
-
- @Test
- public void testConvertMD5() {
- Assert.assertEquals("", RedisUtil.convertMD5(""));
- Assert.assertEquals("EFG", RedisUtil.convertMD5("123"));
- Assert.assertEquals("\u0012\u001B\u001B", RedisUtil.convertMD5("foo"));
- Assert.assertEquals("PQ*R^", RedisUtil.convertMD5("$%^&*"));
- }
-
- @Test
- public void testConvertMD52() {
- Assert.assertEquals("\u001A\u0001\u0018\u0018R\u001A\u0001\u0018" +
- "\u0018Q=\u001A7\u001C\u0015\u0000",
- RedisUtil.convertMD5(null, null));
- Assert.assertEquals("\u0012\u001B\u001BR\u001A\u0001\u0018\u0018Q=" +
- "\u001A7\u001C\u0015\u0000", RedisUtil.convertMD5("foo", null));
- Assert.assertEquals("\u001A\u0001\u0018\u0018R\u0012\u001B\u001BQ=" +
- "\u001A7\u001C\u0015\u0000", RedisUtil.convertMD5(null, "foo"));
- Assert.assertEquals("RQ=\u001A7\u001C\u0015\u0000",
- RedisUtil.convertMD5("", ""));
- Assert.assertEquals("\u0012\u001B\u001BR\u0012\u001B\u001BQ=\u001A7" +
- "\u001C\u0015\u0000", RedisUtil.convertMD5("foo", "foo"));
- Assert.assertEquals("EF×PQGR\u0012\u001B\u001BQ=\u001A7\u001C\u0015" +
- "\u0000", RedisUtil.convertMD5("12£$%3", "foo"));
- }
-
- @Test
- public void testGetAddress() {
- Assert.assertEquals("", RedisUtil.getAddress(""));
- Assert.assertEquals("foobarbaz", RedisUtil.getAddress("foobarbaz"));
- Assert.assertEquals("foo", RedisUtil.getAddress("foo&bar&baz"));
- }
-}
From bada63212a93613572f9d0a331fc1097dee94afd Mon Sep 17 00:00:00 2001
From: MySelf <1341933031@qq.com>
Date: Sun, 18 Aug 2019 11:42:00 +0800
Subject: [PATCH 2/7] =?UTF-8?q?=E5=A4=A9=C3=A4=C3=A6=C2=BB=E5=8A=A0?=
=?UTF-8?q?=E6=B3=A8=E8=A7=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
README.md | 1 +
doc/echo.md | 12 ++++++++++++
.../unclecatmyself/demo1/EchoClient.java | 19 ++++++++++++++++---
.../demo1/EchoClientHandler.java | 2 ++
.../unclecatmyself/demo1/EchoServer.java | 4 ++--
5 files changed, 33 insertions(+), 5 deletions(-)
create mode 100644 doc/echo.md
diff --git a/README.md b/README.md
index f1c27d2..6baeebb 100644
--- a/README.md
+++ b/README.md
@@ -17,6 +17,7 @@
## 官方教程
+- [1、Echo简单通讯](doc/echo.md) [地址](https://github.com/AwakenCN/InChat/tree/official-demo/src/main/java/com/github/unclecatmyself/demo1)
## 公众号：Java猫说
diff --git a/doc/echo.md b/doc/echo.md
new file mode 100644
index 0000000..7a4ad78
--- /dev/null
+++ b/doc/echo.md
@@ -0,0 +1,12 @@
+## Echo简易通讯案例
+
+> 版本：netty 4.1.*
+>
+> 申明：本文旨在重新分享讨论Netty官方相关案例，添加部分个人理解与要点解析。
+
+这个是InChat的案例[地址](https://github.com/AwakenCN/InChat/tree/official-demo/src/main/java/com/github/unclecatmyself/demo1)，里面补充了详细的注释，比起官方会容易看一点。
+
+官方案例地址：https://netty.io/4.1/xref/io/netty/example/echo/package-summary.html
+
+
+
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java b/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java
index 6465102..52c9f39 100644
--- a/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoClient.java
@@ -11,27 +11,36 @@
/**
* @ClassName EchoClient
- * @Description TODO
+ * @Description 一个简单的应答通讯的实例
* @Author MySelf
* @Date 2019/8/17 17:56
* @Version 1.0
**/
public final class EchoClient {
+ //判断是否加密
static final boolean SSL = System.getProperty("ssl") != null;
+ //监听本地服务
static final String HOST = System.getProperty("host", "127.0.0.1");
+ //监听端口
static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
+ //发送消息的大小，用于EchoClientHandler
static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
public static void main(String[] args) throws Exception {
+ //公共抽象类，安全套接字协议实现充当工厂SSLEngine和SslHandler。在内部，它通过JDK SSLContext或OpenSSL 实现SSL_CTX
final SslContext sslCtx;
if (SSL){
+ //用于配置新SslContext以进行创建的构建器
sslCtx = SslContextBuilder.forClient()
+ //用于验证远程端点证书的可信管理器
+ //InsecureTrustManagerFactory:在TrustManagerFactory没有任何验证的情况下信任所有X.509证书的不安全因素
+ //注：切勿TrustManagerFactory在生产中使用它。它纯粹是出于测试目的，因此非常不安全。
.trustManager(InsecureTrustManagerFactory.INSTANCE).build();
}else {
sslCtx = null;
}
-
+ //事件循环
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
@@ -42,16 +51,20 @@ public static void main(String[] args) throws Exception {
@Override
protected void initChannel(SocketChannel sc) throws Exception {
ChannelPipeline p = sc.pipeline();
+ //了解SslContext的用法
if (sslCtx != null){
p.addLast(sslCtx.newHandler(sc.alloc(),HOST,PORT));
}
p.addLast(new EchoClientHandler());
}
});
-
+ //这个sync后的代码均会执行
ChannelFuture f = b.connect(HOST,PORT).sync();
+ System.out.println("before-----");
+ //这个sync后的代码不会执行
f.channel().closeFuture().sync();
+ System.out.println("after-----");
}finally {
group.shutdownGracefully();
}
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java b/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java
index db3e6fa..6ecd414 100644
--- a/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoClientHandler.java
@@ -17,6 +17,8 @@ public class EchoClientHandler extends ChannelInboundHandlerAdapter {
private final ByteBuf firstMessage;
public EchoClientHandler(){
+ //获取EchoClient的SIZE
+ //Unpooled:ByteBuf通过分配新空间或通过包装或复制现有字节数组，字节缓冲区和字符串来创建新的
firstMessage = Unpooled.buffer(EchoClient.SIZE);
for (int i = 0; i < firstMessage.capacity(); i++){
firstMessage.writeByte((byte)i);
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java b/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
index e1cfce4..b9bbf8c 100644
--- a/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
@@ -27,6 +27,7 @@ public final class EchoServer {
public static void main(String[] args) throws Exception {
final SslContext sslCtx;
if (SSL){
+ //SelfSignedCertificate:生成临时自签名证书以进行测试
SelfSignedCertificate ssc = new SelfSignedCertificate();
sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
}else{
@@ -51,8 +52,7 @@ protected void initChannel(SocketChannel ch) throws Exception {
}
p.addLast(serverHandler);
}
- })
- ;
+ });
ChannelFuture f = b.bind(PORT).sync();
From 251cc441b9ddbac229faf343922847d5423bc1d5 Mon Sep 17 00:00:00 2001
From: MySelf <1341933031@qq.com>
Date: Sun, 18 Aug 2019 11:56:55 +0800
Subject: [PATCH 3/7] update
---
doc/echo.md | 238 ++++++++++++++++++
.../unclecatmyself/demo1/EchoServer.java | 2 +-
2 files changed, 239 insertions(+), 1 deletion(-)
diff --git a/doc/echo.md b/doc/echo.md
index 7a4ad78..47c1861 100644
--- a/doc/echo.md
+++ b/doc/echo.md
@@ -8,5 +8,243 @@
官方案例地址：https://netty.io/4.1/xref/io/netty/example/echo/package-summary.html
+### 正文
+- EchoClient（客户端）
+- EchoClientHandler
+- EchoServer（服务端）
+- EchoServerHandler
+### 要点介绍
+
+- SslContext
+
+官方介绍：https://netty.io/4.1/api/io/netty/handler/ssl/SslContext.html
+
+公共抽象类，安全套接字协议实现充当工厂SSLEngine和SslHandler。在内部，它通过JDK SSLContext或OpenSSL 实现SSL_CTX，还有关于它的使用方式，如果你需要ssl加密的话
+
+- SslContextBuilder
+
+官方介绍：https://netty.io/4.1/api/io/netty/handler/ssl/SslContextBuilder.html
+
+用于配置新SslContext以进行创建的构建器，其中包含多个方法这里就不多补充，大家可以去看看
+
+- InsecureTrustManagerFactory
+
+官方介绍：https://netty.io/4.1/api/io/netty/handler/ssl/util/InsecureTrustManagerFactory.html
+
+在TrustManagerFactory没有任何验证的情况下信任所有X.509证书的不安全因素
+
+> 注意：切勿TrustManagerFactory在生产中使用它。它纯粹是出于测试目的，因此非常不安全。
+
+- SelfSignedCertificate
+
+官方介绍：https://netty.io/4.1/api/io/netty/handler/ssl/util/SelfSignedCertificate.html
+
+生成临时自签名证书以进行测试
+
+> 注意：切勿在生产中使用此类生成的证书和私钥。它纯粹是出于测试目的，因此非常不安全。它甚至使用不安全的伪随机生成器在内部更快地生成
+
+### 项目源码
+
+- EchoClient
+
+```java
+/**
+ * @ClassName EchoClient
+ * @Description 一个简单的应答通讯的实例
+ * @Author MySelf
+ * @Date 2019/8/17 17:56
+ * @Version 1.0
+ **/
+public final class EchoClient {
+
+ //判断是否加密
+ static final boolean SSL = System.getProperty("ssl") != null;
+ //监听本地服务
+ static final String HOST = System.getProperty("host", "127.0.0.1");
+ //监听端口
+ static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
+ //发送消息的大小，用于EchoClientHandler
+ static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
+
+ public static void main(String[] args) throws Exception {
+ //公共抽象类，安全套接字协议实现充当工厂SSLEngine和SslHandler。在内部，它通过JDK SSLContext或OpenSSL 实现SSL_CTX
+ final SslContext sslCtx;
+ if (SSL){
+ //用于配置新SslContext以进行创建的构建器
+ sslCtx = SslContextBuilder.forClient()
+ //用于验证远程端点证书的可信管理器
+ //InsecureTrustManagerFactory:在TrustManagerFactory没有任何验证的情况下信任所有X.509证书的不安全因素
+ //注：切勿TrustManagerFactory在生产中使用它。它纯粹是出于测试目的，因此非常不安全。
+ .trustManager(InsecureTrustManagerFactory.INSTANCE).build();
+ }else {
+ sslCtx = null;
+ }
+ //事件循环
+ EventLoopGroup group = new NioEventLoopGroup();
+ try {
+ Bootstrap b = new Bootstrap();
+ b.group(group)
+ .channel(NioSocketChannel.class)
+ .option(ChannelOption.TCP_NODELAY,true)
+ .handler(new ChannelInitializer() {
+ @Override
+ protected void initChannel(SocketChannel sc) throws Exception {
+ ChannelPipeline p = sc.pipeline();
+ //了解SslContext的用法
+ if (sslCtx != null){
+ p.addLast(sslCtx.newHandler(sc.alloc(),HOST,PORT));
+ }
+ p.addLast(new EchoClientHandler());
+ }
+ });
+ //这个sync后的代码均会执行
+ ChannelFuture f = b.connect(HOST,PORT).sync();
+ System.out.println("before-----");
+
+ //这个sync后的代码不会执行
+ f.channel().closeFuture().sync();
+ System.out.println("after-----");
+ }finally {
+ group.shutdownGracefully();
+ }
+ }
+
+}
+```
+
+- EchoClientHandler
+
+```java
+/**
+ * @ClassName EchoClientHandler
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/17 18:06
+ * @Version 1.0
+ **/
+public class EchoClientHandler extends ChannelInboundHandlerAdapter {
+
+ private final ByteBuf firstMessage;
+
+ public EchoClientHandler(){
+ //获取EchoClient的SIZE
+ //Unpooled:ByteBuf通过分配新空间或通过包装或复制现有字节数组，字节缓冲区和字符串来创建新的
+ firstMessage = Unpooled.buffer(EchoClient.SIZE);
+ for (int i = 0; i < firstMessage.capacity(); i++){
+ firstMessage.writeByte((byte)i);
+ }
+ }
+
+ @Override
+ public void channelActive(ChannelHandlerContext ctx) throws Exception {
+ ctx.writeAndFlush(firstMessage);
+ }
+
+ @Override
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+ ctx.write(msg);
+ }
+
+ @Override
+ public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ ctx.flush();
+ }
+
+ @Override
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ cause.printStackTrace();
+ ctx.close();
+ }
+}
+```
+
+- EchoServer
+
+```java
+/**
+ * @ClassName EchoServer
+ * @Description 服务端
+ * @Author MySelf
+ * @Date 2019/8/17 18:15
+ * @Version 1.0
+ **/
+public final class EchoServer {
+
+ static final boolean SSL = System.getProperty("ssl") != null;
+ static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
+
+ public static void main(String[] args) throws Exception {
+ final SslContext sslCtx;
+ if (SSL){
+ //SelfSignedCertificate:生成临时自签名证书以进行测试
+ SelfSignedCertificate ssc = new SelfSignedCertificate();
+ sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
+ }else{
+ sslCtx = null;
+ }
+
+ EventLoopGroup bossGroup = new NioEventLoopGroup(1);
+ EventLoopGroup workerGroup = new NioEventLoopGroup();
+ final EchoServerHandler serverHandler = new EchoServerHandler();
+ try {
+ ServerBootstrap b = new ServerBootstrap();
+ b.group(bossGroup,workerGroup)
+ .channel(NioServerSocketChannel.class)
+ .option(ChannelOption.SO_BACKLOG,100)
+ .handler(new LoggingHandler(LogLevel.INFO))
+ .childHandler(new ChannelInitializer() {
+ @Override
+ protected void initChannel(SocketChannel ch) throws Exception {
+ ChannelPipeline p = ch.pipeline();
+ if (sslCtx != null){
+ p.addLast(sslCtx.newHandler(ch.alloc()));
+ }
+ p.addLast(serverHandler);
+ }
+ });
+
+ ChannelFuture f = b.bind(PORT).sync();
+
+ f.channel().closeFuture().sync();
+
+ }finally {
+ bossGroup.shutdownGracefully();
+ workerGroup.shutdownGracefully();
+ }
+
+ }
+
+}
+```
+
+- EchoServerHandler
+
+```java
+/**
+ * @ClassName EchoServerHandler
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/17 18:14
+ * @Version 1.0
+ **/
+@ChannelHandler.Sharable
+public class EchoServerHandler extends ChannelInboundHandlerAdapter {
+ @Override
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+ ctx.write(msg);
+ }
+
+ @Override
+ public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ ctx.flush();
+ }
+
+ @Override
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ cause.printStackTrace();
+ ctx.close();
+ }
+}
+```
\ No newline at end of file
diff --git a/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java b/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
index b9bbf8c..02d4320 100644
--- a/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
+++ b/src/main/java/com/github/unclecatmyself/demo1/EchoServer.java
@@ -14,7 +14,7 @@
/**
* @ClassName EchoServer
- * @Description TODO
+ * @Description 服务端
* @Author MySelf
* @Date 2019/8/17 18:15
* @Version 1.0
From 7de355aa641f9cb5dd9871cecbe35cbd2ebd2d06 Mon Sep 17 00:00:00 2001
From: MySelf <1341933031@qq.com>
Date: Mon, 19 Aug 2019 21:06:04 +0800
Subject: [PATCH 4/7] =?UTF-8?q?=E6=B7=BB=E5=8A=A0discard?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
doc/discard.md | 8 +++
.../unclecatmyself/demo2/DiscardClient.java | 71 +++++++++++++++++++
.../demo2/DiscardClientHandler.java | 71 +++++++++++++++++++
.../unclecatmyself/demo2/DiscardServer.java | 71 +++++++++++++++++++
.../demo2/DiscardServerHandler.java | 26 +++++++
5 files changed, 247 insertions(+)
create mode 100644 doc/discard.md
create mode 100644 src/main/java/com/github/unclecatmyself/demo2/DiscardClient.java
create mode 100644 src/main/java/com/github/unclecatmyself/demo2/DiscardClientHandler.java
create mode 100644 src/main/java/com/github/unclecatmyself/demo2/DiscardServer.java
create mode 100644 src/main/java/com/github/unclecatmyself/demo2/DiscardServerHandler.java
diff --git a/doc/discard.md b/doc/discard.md
new file mode 100644
index 0000000..2d694bb
--- /dev/null
+++ b/doc/discard.md
@@ -0,0 +1,8 @@
+## 无限异步发送数据流
+
+> 版本：netty 4.1.*
+>
+> 申明：本文旨在重新分享讨论Netty官方相关案例，添加部分个人理解与要点解析。
+
+
+
diff --git a/src/main/java/com/github/unclecatmyself/demo2/DiscardClient.java b/src/main/java/com/github/unclecatmyself/demo2/DiscardClient.java
new file mode 100644
index 0000000..309f6dd
--- /dev/null
+++ b/src/main/java/com/github/unclecatmyself/demo2/DiscardClient.java
@@ -0,0 +1,71 @@
+package com.github.unclecatmyself.demo2;
+
+import com.github.unclecatmyself.demo1.EchoClientHandler;
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.ssl.SslContext;
+import io.netty.handler.ssl.SslContextBuilder;
+import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
+
+/**
+ * @ClassName DiscardClient
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/19 20:38
+ * @Version 1.0
+ **/
+public final class DiscardClient {
+
+ //判断是否加密
+ static final boolean SSL = System.getProperty("ssl") != null;
+ //监听本地服务
+ static final String HOST = System.getProperty("host", "127.0.0.1");
+ //监听端口
+ static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
+ //发送消息的大小，用于EchoClientHandler
+ static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
+
+ public static void main(String[] args) throws Exception {
+ //公共抽象类，安全套接字协议实现充当工厂SSLEngine和SslHandler。在内部，它通过JDK SSLContext或OpenSSL 实现SSL_CTX
+ final SslContext sslCtx;
+ if (SSL){
+ //用于配置新SslContext以进行创建的构建器
+ sslCtx = SslContextBuilder.forClient()
+ //用于验证远程端点证书的可信管理器
+ //InsecureTrustManagerFactory:在TrustManagerFactory没有任何验证的情况下信任所有X.509证书的不安全因素
+ //注：切勿TrustManagerFactory在生产中使用它。它纯粹是出于测试目的，因此非常不安全。
+ .trustManager(InsecureTrustManagerFactory.INSTANCE).build();
+ }else {
+ sslCtx = null;
+ }
+ //事件循环
+ EventLoopGroup group = new NioEventLoopGroup();
+ try {
+ Bootstrap b = new Bootstrap();
+ b.group(group)
+ .channel(NioSocketChannel.class)
+ .option(ChannelOption.TCP_NODELAY,true)
+ .handler(new ChannelInitializer() {
+ @Override
+ protected void initChannel(SocketChannel sc) throws Exception {
+ ChannelPipeline p = sc.pipeline();
+ //了解SslContext的用法
+ if (sslCtx != null){
+ p.addLast(sslCtx.newHandler(sc.alloc(),HOST,PORT));
+ }
+ p.addLast(new DiscardClientHandler());
+ }
+ });
+
+ ChannelFuture f = b.connect(HOST,PORT).sync();
+
+ f.channel().closeFuture().sync();
+ }finally {
+ group.shutdownGracefully();
+ }
+ }
+
+}
diff --git a/src/main/java/com/github/unclecatmyself/demo2/DiscardClientHandler.java b/src/main/java/com/github/unclecatmyself/demo2/DiscardClientHandler.java
new file mode 100644
index 0000000..24f67a0
--- /dev/null
+++ b/src/main/java/com/github/unclecatmyself/demo2/DiscardClientHandler.java
@@ -0,0 +1,71 @@
+package com.github.unclecatmyself.demo2;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+
+/**
+ * @ClassName DiscardClientHandler
+ * @Description TODO
+ * @Author MySelf
+ * @Date 2019/8/19 20:38
+ * @Version 1.0
+ **/
+public class DiscardClientHandler extends SimpleChannelInboundHandler