|
@@ -43,15 +43,17 @@ public class SocketBufferServiceImpl implements SocketBufferService {
|
|
|
private RedisCache redisCache;
|
|
|
|
|
|
// 创建一个线程池
|
|
|
- private ExecutorService executorService;
|
|
|
+ private static ExecutorService executorService;
|
|
|
|
|
|
- @Override
|
|
|
- public List<Order> bufferSeparator(byte[] buffer) {
|
|
|
+ static {
|
|
|
// 创建一个线程池
|
|
|
executorService = new ThreadPoolExecutor(5, 30
|
|
|
, 60L, TimeUnit.SECONDS
|
|
|
, new SynchronousQueue<Runnable>(true));
|
|
|
+ }
|
|
|
|
|
|
+ @Override
|
|
|
+ public List<Order> bufferSeparator(byte[] buffer) {
|
|
|
List<Order> orderList = new ArrayList<>();
|
|
|
String bufferStr = ByteUtil.byteArray2HexString(buffer);
|
|
|
//通过固定的头部 87CD0008 将多条消息拆分开
|