From bf5f7c66329e05566df909972384dc86d63eca44 Mon Sep 17 00:00:00 2001
From: hacker918 <33892023+hacker918@users.noreply.github.com>
Date: Wed, 22 Nov 2017 16:17:09 +0800
Subject: [PATCH] MessageHandlerManager.java

MessageHandlerManager
---
 .../demo/MessageHandlerManager.java           | 96 +++++++++++++++++++
 1 file changed, 96 insertions(+)
 create mode 100644 demo/src/main/java/cn/dreamtobe/messagehandler/demo/MessageHandlerManager.java

diff --git a/demo/src/main/java/cn/dreamtobe/messagehandler/demo/MessageHandlerManager.java b/demo/src/main/java/cn/dreamtobe/messagehandler/demo/MessageHandlerManager.java
new file mode 100644
index 0000000..7e8a950
--- /dev/null
+++ b/demo/src/main/java/cn/dreamtobe/messagehandler/demo/MessageHandlerManager.java
@@ -0,0 +1,96 @@
+import java.io.FileInputStream;
+import java.util.Enumeration;
+import java.util.Hashtable;
+import java.util.Properties;
+import org.apache.log4j.Logger;
+public class MessageHandlerManager
+{
+  private static MsgHandlerManager msgHandlerMgr = null;
+  private static Object obj = new Object();
+  static Logger logger = Logger.getLogger(MsgHandlerManager.class);
+  private static Hashtable<String, IMsgHandler> handlers = new Hashtable();
+
+  private MsgHandlerManager()
+  {
+    try
+    {
+    
+      initMsgHander();
+    }
+    catch (Exception e)
+    {
+      logger.error("exception happens when loading handler ", e);
+    }
+  }
+
+  public static synchronized MsgHandlerManager getInstance()
+  {
+    if (msgHandlerMgr == null)
+      synchronized (obj)
+      {
+        if (msgHandlerMgr == null)
+          msgHandlerMgr = new MsgHandlerManager();
+      }
+    return msgHandlerMgr;
+  }
+
+
+
+
+ 
+  public synchronized IMsgHandler getMsgHandler(String hname)
+     
+  {
+    IMsgHandler iMsgHandler = null;
+    try
+    {
+      iMsgHandler = (IMsgHandler)handlers.get(hname);
+      if (iMsgHandler == null)
+      {
+     
+        initMsgHander();
+        iMsgHandler = (IMsgHandler)handlers.get(hname);
+        
+        }
+      }
+    catch (Exception e)
+    {   logger.error("use default hdr", e);
+    	
+       }
+    return iMsgHandler;
+  }
+
+private void initMsgHander()
+throws Exception
+{
+try
+{
+  Properties properties = new Properties();
+  String str2 = ConfigFiles.getInstance().getMsgHandlersFileName();
+ // logger.info(str2);
+  FileInputStream fileInputStream = new FileInputStream(str2);
+  properties.load(fileInputStream);
+  Enumeration localEnumeration = properties.keys();
+  while (localEnumeration.hasMoreElements())
+  {
+    String str1 = (String)localEnumeration.nextElement();
+    if (handlers.containsKey(str1))
+      continue;
+    try
+    {
+    	handlers.put(str1, (IMsgHandler)ObjectFactory.createObject(properties.getProperty(str1)));
+    }
+    catch (Exception localException2)
+    {
+    	logger.error("load msg handler error : " + str1, localException2);
+    }
+  }
+  fileInputStream.close();
+}
+catch (Exception e)
+{
+  throw e;
+}
+}
+}
+