From 462e9bc9200e077ff8d1e720275ec4c2f98af710 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期四, 06 八月 2020 08:16:44 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/BarcodeThread.java | 53 ++++++++++++++++++++++++++
src/main/java/com/zy/core/ServerBootstrap.java | 9 ++++
2 files changed, 61 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index 6ecf80a..084a51b 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -4,6 +4,7 @@
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.properties.SlaveProperties;
+import com.zy.core.thread.BarcodeThread;
import com.zy.core.thread.CrnThread;
import com.zy.core.thread.DevpThread;
import lombok.extern.slf4j.Slf4j;
@@ -63,13 +64,19 @@
SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread);
}
- // 鍒濆鍖栫珯鐐圭嚎绋�
+ // 鍒濆鍖栬緭閫佺嚎绾跨▼
for (Slave devp : slaveProperties.getDevp()) {
DevpThread devpThread = new DevpThread(devp);
new Thread(devpThread).start();
SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread);
}
+ // 鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼
+ for (Slave barcode : slaveProperties.getBarcode()) {
+ BarcodeThread barcodeThread = new BarcodeThread(barcode);
+ new Thread(barcodeThread).start();
+ SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread);
+ }
}
diff --git a/src/main/java/com/zy/core/thread/BarcodeThread.java b/src/main/java/com/zy/core/thread/BarcodeThread.java
new file mode 100644
index 0000000..6c4a7eb
--- /dev/null
+++ b/src/main/java/com/zy/core/thread/BarcodeThread.java
@@ -0,0 +1,53 @@
+package com.zy.core.thread;
+
+import com.zy.core.Slave;
+import com.zy.core.ThreadHandler;
+import com.zy.core.cache.MessageQueue;
+import com.zy.core.enums.SlaveType;
+import com.zy.core.model.Task;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 鏉＄爜鎵弿浠嚎绋�
+ * Created by vincent on 2020/8/4
+ */
+@Data
+@Slf4j
+public class BarcodeThread implements Runnable, ThreadHandler {
+
+ private Slave slave;
+
+ public BarcodeThread(Slave slave) {
+ this.slave = slave;
+ connect();
+ }
+
+ @Override
+ @SuppressWarnings("InfiniteLoopStatement")
+ public void run() {
+ while (true) {
+ try {
+ Task task = MessageQueue.poll(SlaveType.Barcode, slave.getId());
+ if (task != null) {
+ System.out.println("浠诲姟"+task.getId());
+ }
+ Thread.sleep(3000);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ }
+
+ @Override
+ public boolean connect() {
+
+ return false;
+ }
+
+ @Override
+ public void close() {
+
+ }
+}
--
Gitblit v1.9.1