From 42af11ca3a84e13d1f55207b2770e2454a861983 Mon Sep 17 00:00:00 2001 From: Junjie <540245094@qq.com> Date: 星期五, 01 八月 2025 17:05:03 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/cache/MessageQueue.java | 120 ++++++++++++++++++++++------------------------------------- 1 files changed, 45 insertions(+), 75 deletions(-) diff --git a/src/main/java/com/zy/core/cache/MessageQueue.java b/src/main/java/com/zy/core/cache/MessageQueue.java index ec0be29..9788407 100644 --- a/src/main/java/com/zy/core/cache/MessageQueue.java +++ b/src/main/java/com/zy/core/cache/MessageQueue.java @@ -1,13 +1,11 @@ package com.zy.core.cache; -import com.zy.core.Slave; import com.zy.core.enums.SlaveType; import com.zy.core.model.Task; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; -import java.util.concurrent.LinkedBlockingQueue; /** * 娑堟伅闃熷垪 @@ -15,46 +13,36 @@ */ public class MessageQueue { - // 杈撻�佺嚎mq浜ゆ崲鏈� - private static final Map<Integer, ConcurrentLinkedQueue<Task>> DEVP_EXCHANGE = new ConcurrentHashMap<>(); - // 鏉$爜鎵弿浠猰q浜ゆ崲鏈� - private static final Map<Integer, ConcurrentLinkedQueue<Task>> BARCODE_EXCHANGE = new ConcurrentHashMap<>(); - // Led鐏� mq浜ゆ崲鏈� - private static final Map<Integer, LinkedBlockingQueue<Task>> LED_EXCHANGE = new ConcurrentHashMap<>(); - // 纾呯Оmq浜ゆ崲鏈� - private static final Map<Integer, ConcurrentLinkedQueue<Task>> SCALE_EXCHANGE = new ConcurrentHashMap<>(); - // 鍙拌溅mq浜ゆ崲鏈� - private static final Map<Integer, ConcurrentLinkedQueue<Task>> CAR_EXCHANGE = new ConcurrentHashMap<>(); //鍥涘悜绌挎杞q浜ゆ崲鏈� private static final Map<Integer, ConcurrentLinkedQueue<Task>> SHUTTLE_EXCHANGE = new ConcurrentHashMap<>(); //鎻愬崌鏈簃q浜ゆ崲鏈� private static final Map<Integer, ConcurrentLinkedQueue<Task>> LIFT_EXCHANGE = new ConcurrentHashMap<>(); + //璐у弶鎻愬崌鏈簃q浜ゆ崲鏈� + private static final Map<Integer, ConcurrentLinkedQueue<Task>> FORK_LIFT_EXCHANGE = new ConcurrentHashMap<>(); + //璐у弶鎻愬崌鏈篗aster mq浜ゆ崲鏈� + private static final Map<Integer, ConcurrentLinkedQueue<Task>> FORK_LIFT_MASTER_EXCHANGE = new ConcurrentHashMap<>(); + //Traffic Control mq浜ゆ崲鏈� + private static final Map<Integer, ConcurrentLinkedQueue<Task>> TRAFFIC_CONTROL_EXCHANGE = new ConcurrentHashMap<>(); /** * mq 浜ゆ崲鏈哄垵濮嬪寲 */ - public static void init(SlaveType type, Slave slave) { + public static void init(SlaveType type, Integer id) { switch (type) { - case Devp: - DEVP_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); - break; - case Barcode: - BARCODE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); - break; - case Led: - LED_EXCHANGE.put(slave.getId(), new LinkedBlockingQueue<>(1)); - break; - case Scale: - SCALE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); - break; - case Car: - CAR_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); - break; case Shuttle: - SHUTTLE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); + SHUTTLE_EXCHANGE.put(id, new ConcurrentLinkedQueue<>()); + break; + case ForkLift: + FORK_LIFT_EXCHANGE.put(id, new ConcurrentLinkedQueue<>()); + break; + case ForkLiftMaster: + FORK_LIFT_MASTER_EXCHANGE.put(id, new ConcurrentLinkedQueue<>()); break; case Lift: - LIFT_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); + LIFT_EXCHANGE.put(id, new ConcurrentLinkedQueue<>()); + break; + case TrafficControl: + TRAFFIC_CONTROL_EXCHANGE.put(id, new ConcurrentLinkedQueue<>()); break; default: break; @@ -67,20 +55,16 @@ */ public static boolean offer(SlaveType type, Integer id, Task task) { switch (type) { - case Devp: - return DEVP_EXCHANGE.get(id).offer(task); - case Barcode: - return BARCODE_EXCHANGE.get(id).offer(task); - case Led: - return LED_EXCHANGE.get(id).offer(task); - case Scale: - return SCALE_EXCHANGE.get(id).offer(task); - case Car: - return CAR_EXCHANGE.get(id).offer(task); case Shuttle: return SHUTTLE_EXCHANGE.get(id).offer(task); + case ForkLift: + return FORK_LIFT_EXCHANGE.get(id).offer(task); + case ForkLiftMaster: + return FORK_LIFT_MASTER_EXCHANGE.get(id).offer(task); case Lift: return LIFT_EXCHANGE.get(id).offer(task); + case TrafficControl: + return TRAFFIC_CONTROL_EXCHANGE.get(id).offer(task); default: return false; } @@ -92,20 +76,16 @@ */ public static Task poll(SlaveType type, Integer id) { switch (type) { - case Devp: - return DEVP_EXCHANGE.get(id).poll(); - case Barcode: - return BARCODE_EXCHANGE.get(id).poll(); - case Led: - return LED_EXCHANGE.get(id).poll(); - case Scale: - return SCALE_EXCHANGE.get(id).poll(); - case Car: - return CAR_EXCHANGE.get(id).poll(); case Shuttle: return SHUTTLE_EXCHANGE.get(id).poll(); + case ForkLift: + return FORK_LIFT_EXCHANGE.get(id).poll(); + case ForkLiftMaster: + return FORK_LIFT_MASTER_EXCHANGE.get(id).poll(); case Lift: return LIFT_EXCHANGE.get(id).poll(); + case TrafficControl: + return TRAFFIC_CONTROL_EXCHANGE.get(id).poll(); default: return null; } @@ -116,20 +96,16 @@ */ public static Task peek(SlaveType type, Integer id) { switch (type) { - case Devp: - return DEVP_EXCHANGE.get(id).peek(); - case Barcode: - return BARCODE_EXCHANGE.get(id).peek(); - case Led: - return LED_EXCHANGE.get(id).peek(); - case Scale: - return SCALE_EXCHANGE.get(id).peek(); - case Car: - return CAR_EXCHANGE.get(id).peek(); case Shuttle: return SHUTTLE_EXCHANGE.get(id).peek(); + case ForkLift: + return FORK_LIFT_EXCHANGE.get(id).peek(); + case ForkLiftMaster: + return FORK_LIFT_MASTER_EXCHANGE.get(id).peek(); case Lift: return LIFT_EXCHANGE.get(id).peek(); + case TrafficControl: + return TRAFFIC_CONTROL_EXCHANGE.get(id).peek(); default: return null; } @@ -137,27 +113,21 @@ public static void clear(SlaveType type, Integer id){ switch (type) { - case Devp: - DEVP_EXCHANGE.get(id).clear(); - break; - case Barcode: - BARCODE_EXCHANGE.get(id).clear(); - break; - case Led: - LED_EXCHANGE.get(id).clear(); - break; - case Scale: - SCALE_EXCHANGE.get(id).clear(); - break; - case Car: - CAR_EXCHANGE.get(id).clear(); - break; case Shuttle: SHUTTLE_EXCHANGE.get(id).clear(); break; + case ForkLift: + FORK_LIFT_EXCHANGE.get(id).clear(); + break; + case ForkLiftMaster: + FORK_LIFT_MASTER_EXCHANGE.get(id).clear(); + break; case Lift: LIFT_EXCHANGE.get(id).clear(); break; + case TrafficControl: + TRAFFIC_CONTROL_EXCHANGE.get(id).clear(); + break; default: break; } -- Gitblit v1.9.1