事件系统

转换器
yaml文件读取

Author: Evan Hu

pom.xml

@@ -149,6 +149,11 @@
             <version>4.13.1</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.esotericsoftware.yamlbeans</groupId>
+            <artifactId>yamlbeans</artifactId>
+            <version>1.15</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/info/xiaomo/gengine/config/converters/IntegerArrayConverter.java

@@ -0,0 +1,23 @@
+/**
+ * 创建日期:  2017年08月19日 9:57
+ * 创建作者:  杨 强  <[email protected]>
+ */
+package info.xiaomo.gengine.config.converters;
+
+
+import info.xiaomo.gengine.config.IConverter;
+
+/**
+ * @author YangQiang
+ */
+public class IntegerArrayConverter implements IConverter<String, int[]> {
+    @Override
+    public int[] convert(String s) {
+        String[] strs = s.split("#");
+        int[] ret = new int[strs.length];
+        for (int i = 0; i < ret.length; i++) {
+            ret[i] = Integer.parseInt(strs[i]);
+        }
+        return ret;
+    }
+}

src/main/java/info/xiaomo/gengine/config/converters/IntegerMapConverter.java

@@ -0,0 +1,27 @@
+/**
+ * 创建日期:  2017年08月19日 10:08
+ * 创建作者:  杨 强  <[email protected]>
+ */
+package info.xiaomo.gengine.config.converters;
+
+
+import java.util.HashMap;
+import java.util.Map;
+import info.xiaomo.gengine.config.IConverter;
+
+/**
+ * @author YangQiang
+ */
+public class IntegerMapConverter implements IConverter<int[], Map<Integer, Integer>> {
+    @Override
+    public Map<Integer, Integer> convert(int[] ints) {
+        Map<Integer, Integer> map = new HashMap<>(10);
+        if (ints != null) {
+            int step = 2;
+            for (int i = 1; i < ints.length; i += step) {
+                map.put(ints[i - 1], ints[i]);
+            }
+        }
+        return map;
+    }
+}

src/main/java/info/xiaomo/gengine/config/converters/MapConverter.java

@@ -0,0 +1,19 @@
+/**
+ * 创建日期:  2017年08月19日 10:01
+ * 创建作者:  杨 强  <[email protected]>
+ */
+package info.xiaomo.gengine.config.converters;
+
+
+import java.util.Map;
+import info.xiaomo.gengine.config.IConverter;
+
+/**
+ * @author YangQiang
+ */
+public class MapConverter implements IConverter<String, Map<Integer, Integer>> {
+    @Override
+    public Map<Integer, Integer> convert(String s) {
+        return new IntegerArrayConverter().andThen(new IntegerMapConverter()).convert(s);
+    }
+}

src/main/java/info/xiaomo/gengine/config/converters/Matrix3IntConverter.java

@@ -0,0 +1,40 @@
+/**
+ * 创建日期:  2017年08月24日 10:56
+ * 创建作者:  杨 强  <[email protected]>
+ */
+package info.xiaomo.gengine.config.converters;
+
+import info.xiaomo.gengine.config.IConverter;
+import org.apache.commons.beanutils.converters.ArrayConverter;
+import org.apache.commons.beanutils.converters.IntegerConverter;
+
+/**
+ * @author YangQiang
+ */
+public class Matrix3IntConverter implements IConverter<String, int[][][]> {
+    @Override
+    public int[][][] convert(String str) {
+        if (str == null || str.isEmpty()) {
+            return new int[0][][];
+        }
+        // 格式 1,2;3,4|5,6  =>  [[[1, 2], [3, 4]], [[5,6]]]
+        // 基本类型
+        IntegerConverter integerConverter = new IntegerConverter();
+        // 一维数组 默认使用逗号分割
+        ArrayConverter arrayConverter1 = new ArrayConverter(int[].class, integerConverter);
+
+        // 二维数组
+        ArrayConverter arrayConverter2 = new ArrayConverter(int[][].class, arrayConverter1);
+        // 使用分号分割
+        arrayConverter2.setDelimiter(';');
+        arrayConverter2.setAllowedChars(new char[]{','});
+
+        // 二维数组
+        ArrayConverter arrayConverter3 = new ArrayConverter(int[][].class, arrayConverter2);
+        // 使用竖线分割
+        arrayConverter3.setDelimiter('|');
+        arrayConverter3.setAllowedChars(new char[]{';', ','});
+
+        return arrayConverter3.convert(int[][][].class, str);
+    }
+}

src/main/java/info/xiaomo/gengine/event/BasicEventType.java

@@ -0,0 +1,33 @@
+package info.xiaomo.gengine.event;
+
+/**
+ * desc  : 事件类型
+ * Copyright(©) 2017 by xiaomo.
+ */
+public interface BasicEventType {
+	/**
+	 * 登录
+	 */
+	int LOGIN = 1;
+	/**
+	 * 登出
+	 */
+	int LOGOUT = 2;
+	/**
+	 * 服务器分钟心跳
+	 */
+	int SERVER_MINUTE_HEART = 3;
+	/**
+	 * 服务器零点事件
+	 */
+	int SERVER_MIDNIGHT = 4;
+	/**
+	 * 服务器秒心跳
+	 */
+	int SERVER_SECOND_HEART = 5;
+	/**
+	 * 关服事件
+	 */
+	int SERVER_SHUTDOWN = 6;
+
+}

src/main/java/info/xiaomo/gengine/event/EventUtil.java

@@ -0,0 +1,52 @@
+package info.xiaomo.gengine.event;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * 由于事件都是预先注册好的，所以这里不考虑多线程问题，不允许在游戏运行过成中动态添加观察者
+ *
+ * @author 张力
+ * 2014-12-6 上午11:19:00
+ */
+public class EventUtil {
+
+	/**
+	 * 游戏启动就初始化的监听者列表
+	 */
+	private final static Map<Integer, List<IEventListener>> PREPARED_LISTENERS = new HashMap<>(10);
+
+	/**
+	 * 游戏运行中动态添加的监听者列表
+	 */
+	private final static Logger LOGGER = LoggerFactory.getLogger(EventUtil.class);
+
+	public static void addListener(IEventListener listener, Integer type) {
+		List<IEventListener> listenerList = PREPARED_LISTENERS.computeIfAbsent(type, k -> new ArrayList<>());
+		listenerList.add(listener);
+	}
+
+	public static void fireEvent(Integer type) {
+		fireEvent(type, null);
+	}
+
+	public static void fireEvent(Integer type, Object obj) {
+
+		List<IEventListener> listenerList = PREPARED_LISTENERS.get(type);
+		if (listenerList != null) {
+			for (IEventListener listener : listenerList) {
+				try {
+					listener.update(type, obj);
+				} catch (Exception e) {
+					LOGGER.error("事件执行错误", e);
+				}
+			}
+		}
+	}
+
+
+}

src/main/java/info/xiaomo/gengine/event/IEventListener.java

@@ -0,0 +1,16 @@
+package info.xiaomo.gengine.event;
+
+/**
+ * Copyright(©) 2017 by xiaomo.
+ */
+public interface IEventListener {
+
+	/**
+	 * 更新
+	 *
+	 * @param type  type
+	 * @param param param
+	 */
+	void update(Integer type, Object param);
+
+}

src/main/java/info/xiaomo/gengine/utils/YamlUtil.java

@@ -0,0 +1,23 @@
+package info.xiaomo.gengine.utils;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.InputStream;
+import lombok.extern.slf4j.Slf4j;
+import org.yaml.snakeyaml.Yaml;
+
+@Slf4j
+public class YamlUtil {
+
+	public static <T> T read(String file, Class<T> clazz) {
+		InputStream input;
+		try {
+			input = new FileInputStream(file);
+		} catch (FileNotFoundException e) {
+			log.error("读取yaml文件失败:{}", file, e);
+			return null;
+		}
+		Yaml yaml = new Yaml();
+		return yaml.loadAs(input, clazz);
+	}
+}