~wjc/HDLPhotovoltaicDebugAPP.git

New file
			@@ -0,0 +1,239 @@
			package com.hdl.sdk.link.common.event;

			import androidx.annotation.NonNull;
			import androidx.collection.ArrayMap;


			import com.hdl.sdk.link.common.utils.LockArrayMap;
			import com.hdl.sdk.link.common.utils.LockList;
			import com.hdl.sdk.link.common.utils.LogUtils;
			import com.hdl.sdk.link.common.utils.ThreadToolUtils;

			import java.util.ArrayList;
			import java.util.List;
			import java.util.Map;
			import java.util.concurrent.ConcurrentHashMap;
			import java.util.concurrent.ExecutorService;


			/**
			* Created by Tong on 2021/9/22.
			* 事件分发
			*/
			public class EventDispatcher {

			private static final LockList<EventListener> ALL_TOPICS_EVENT = new LockList<EventListener>();//所有主题消息

			// private static final ArrayMap<String, List<EventListener>> EVENT = new ArrayMap<>();
			private static final LockArrayMap<String, List<EventListener>> EVENT = new LockArrayMap<String, List<EventListener>>();

			private static final ExecutorService ioThread = ThreadToolUtils.getInstance().newFixedThreadPool(2);

			private EventDispatcher() {
			}

			private static class SingletonInstance {
			private static final EventDispatcher INSTANCE = new EventDispatcher();
			}

			public static EventDispatcher getInstance() {
			return SingletonInstance.INSTANCE;
			}

			public synchronized void register(String tag, EventListener listener) {
			try {
			if (!EVENT.containsKey(tag)) {
			EVENT.put(tag, new ArrayList<>());
			}
			List<EventListener> events = EVENT.get(tag);
			if (events != null && !events.contains(listener)) {
			events.add(listener);
			LogUtils.i(String.format("增加订阅主题:%s,当前回调数量:%s", tag, events.size()));
			}
			} catch (Exception e) {
			LogUtils.e(e.getMessage());
			}
			}

			public synchronized void registerIo(String tag, EventListener listener) {
			try {
			if (!EVENT.containsKey(tag)) {
			EVENT.put(tag, new ArrayList<>());
			}
			List<EventListener> events = EVENT.get(tag);
			if (events != null && !events.contains(listener)) {
			events.add(listener);
			}
			} catch (Exception e) {
			LogUtils.e(e.getMessage());
			}
			}

			public synchronized void remove(Object tag) {
			ioThread.execute(new Runnable() {
			@Override
			public void run() {
			try {
			if (EVENT.containsKey(tag)) {
			// List<EventListener> list = EVENT.get(tag);
			// for (EventListener eventListener : list) {
			// TYPE.remove(eventListener);
			// }
			EVENT.remove(tag);
			}
			} catch (Exception e) {
			LogUtils.e(e.getMessage());
			}

			}
			});
			}

			public synchronized void remove(Object tag, EventListener listener) {
			ioThread.execute(new Runnable() {
			@Override
			public void run() {
			try {
			if (EVENT.containsKey(tag)) {
			List<EventListener> ev = EVENT.get(tag);
			if (ev != null && !ev.isEmpty()) {
			// TYPE.remove(listener);
			ev.remove(listener);
			LogUtils.i(String.format("移除订阅主题:%s,当前回调数量:%s",tag,ev.size()));
			}
			}
			} catch (Exception e) {
			LogUtils.e(e.getMessage());
			}

			}
			});
			}

			/**
			* 两个主题是否匹配
			* @param desString 字典中的主题
			* @param sourceString 接收到的主题
			* @return
			*/
			boolean isMatch(String desString,String sourceString) {
			String[] des = desString.split("/");
			String[] source = sourceString.split("/");
			if (des.length != source.length) {
			return false;
			}
			for (int i = 0; i < des.length; i++) {
			if (!(des[i].equals(source[i]) \|\| des[i].equals("+"))) {
			if (i != 2) {
			//网关id不判断，可能是Oid,也可能是mac
			return false;
			}
			}
			}
			return true;
			}

			/**
			* 事件分发器，分发所有在接口列表中的事件
			* @param topicTag
			* @param o
			*/
			public synchronized void post(String topicTag, @NonNull Object o) {
			try {
			for (String key : EVENT.keySet()) {
			if (!isMatch(key, topicTag)) {
			continue;
			}
			List<EventListener> list = EVENT.get(key);
			if (list != null && !list.isEmpty()) {
			for (EventListener listener : list) {
			ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
			@Override
			public void run() {
			try {
			if (listener != null) {
			listener.onMessage(o);
			}
			} catch (Exception e) {
			LogUtils.e("post数据异常", o + " " + e.getMessage());
			}
			}
			});
			}
			}
			}
			//所有主题的Listener通知
			if (ALL_TOPICS_EVENT == null \|\| ALL_TOPICS_EVENT.isEmpty()) {
			return;
			}
			//开发分发事件
			for (EventListener listener : ALL_TOPICS_EVENT) {
			ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
			@Override
			public void run() {
			if (listener != null) {
			listener.onMessage(o);
			}
			}
			});
			}
			}catch (Exception e){
			LogUtils.e(e.getMessage());
			}

			}

			/**
			* 文件发送通知 wxr 2022-03-08 15:38:59
			*/
			public synchronized void filePost() {
			//TODO
			}
			/**
			* 注册所有主题消息的监听
			* @param listener
			*/
			public synchronized void registerAllTopicsListener(EventListener listener) {
			try {
			if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.contains(listener)) {
			ALL_TOPICS_EVENT.add(listener);
			}
			// TYPE.put(listener, MAIN_TYPE);
			} catch (Exception e) {
			LogUtils.e(e.getMessage());
			}
			}

			/**
			* 取消所有主题消息的监听
			* @param listener
			*/
			public synchronized void removeAllTopicsListener(EventListener listener) {
			ioThread.execute(new Runnable() {
			@Override
			public void run() {
			try {
			if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.isEmpty()) {
			// TYPE.remove(listener);
			ALL_TOPICS_EVENT.remove(listener);
			}
			} catch (Exception e) {
			LogUtils.e(e.getMessage());
			}
			}
			});
			}

			public synchronized void clear() {
			ALL_TOPICS_EVENT.clear();
			EVENT.clear();
			// TYPE.clear();
			}

			public synchronized void release() {
			clear();
			ioThread.shutdownNow();
			}


			}