消息

Author: houko

server/src/main/java/info/xiaomo/server/StopServerClient.java

@@ -4,6 +4,7 @@
 import info.xiaomo.gameCore.protocol.client.ClientBuilder;
 import info.xiaomo.server.back.BackMessagePool;
 import info.xiaomo.server.back.BackMessageRouter;
+import info.xiaomo.server.protocol.message.gm.ReqCloseServerMessage;
 import info.xiaomo.server.server.ServerOption;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -14,7 +15,7 @@ public class StopServerClient {
     public static void main(String[] args) throws Exception {
 
         try {
-            String optionPath = args[0];
+            String optionPath = "config.properties";
             BackMessagePool pool = new BackMessagePool();
             ServerOption option = new ServerOption(optionPath);
             ClientBuilder builder = new ClientBuilder();
@@ -25,9 +26,9 @@ public static void main(String[] args) throws Exception {
 
             Client client = builder.createClient();
             client.connect(false);
-
+            ReqCloseServerMessage msg = new ReqCloseServerMessage();
             Thread.sleep(1000);
-//            client.sendMsg(msg);
+            client.sendMsg(msg);
             int count = 10;
             while (count > 0) {
                 Thread.sleep(10 * 1000);

server/src/main/java/info/xiaomo/server/back/BackMessagePool.java

@@ -3,6 +3,7 @@
 
 import info.xiaomo.gameCore.protocol.Message;
 import info.xiaomo.gameCore.protocol.MessagePool;
+import info.xiaomo.server.protocol.message.gm.ReqCloseServerMessage;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -27,7 +28,7 @@ public class BackMessagePool implements MessagePool {
     private final Map<Integer, Class<? extends Message>> messages = new HashMap<>();
 
     public BackMessagePool() {
-
+        register(new ReqCloseServerMessage().getId(),ReqCloseServerMessage.class);
     }
 
     @Override

server/src/main/java/info/xiaomo/server/protocol/message/gm/ReqCloseServerMessage.java

@@ -1,29 +1,24 @@
 package info.xiaomo.server.protocol.message.gm;
 
+import info.xiaomo.server.back.BackManager;
 import info.xiaomo.server.server.AbstractMessage;
-import info.xiaomo.server.protocol.proto.GMProto.CloseServerRequest;
-import com.google.protobuf.InvalidProtocolBufferException;
 
 public class ReqCloseServerMessage extends AbstractMessage {
 
-    private CloseServerRequest req;
+    public ReqCloseServerMessage() {
+        this.queueId = 2;
+    }
+
 
     @Override
     public void doAction() {
-
+        BackManager.getInstance().closeServer();
     }
 
-	@Override
-	public void decode(byte[] bytes) throws InvalidProtocolBufferException{
-        this.req = CloseServerRequest.parseFrom(bytes);
-	}
-
     @Override
     public int getId() {
         return 201;
     }
 
-
-
 }
 

server/src/main/java/info/xiaomo/server/protocol/message/gm/ResCloseServerMessage.java

@@ -1,34 +1,34 @@
 package info.xiaomo.server.protocol.message.gm;
 
 import com.google.protobuf.InvalidProtocolBufferException;
-import info.xiaomo.server.protocol.proto.GMProto.CloseServerResponse;
 import info.xiaomo.server.server.AbstractMessage;
+import info.xiaomo.server.protocol.proto.GMProto.CloseServerResponse;
 
 /**
  * 关服返回
  */
 public class ResCloseServerMessage extends AbstractMessage {
 
-    private CloseServerResponse closeServerResponse;
+	private CloseServerResponse res;
 
-    @Override
-    public void decode(byte[] bytes) throws InvalidProtocolBufferException {
-        this.closeServerResponse = CloseServerResponse.parseFrom(bytes);
-    }
+	@Override
+	public void decode(byte[] bytes) throws InvalidProtocolBufferException {
+		this.res = CloseServerResponse.parseFrom(bytes);
+	}
 
+	@Override
+	public int getId() {
+		return 2202;
+	}
 
-    @Override
-    public int getId() {
-        return 2202;
-    }
-
-    public CloseServerResponse getCloseServerResponse() {
-        return closeServerResponse;
-    }
 
-    public void setCloseServerResponse(CloseServerResponse closeServerResponse) {
-        this.closeServerResponse = closeServerResponse;
+    @Override
+    public byte[] getContent() {
+        return res.toByteArray();
     }
 
+	public void setCloseServerResponse(CloseServerResponse res) {
+		this.res = res;
+	}
 }
 

server/src/main/java/info/xiaomo/server/server/GameMessagePool.java

@@ -2,6 +2,7 @@
 
 import info.xiaomo.gameCore.protocol.Message;
 import info.xiaomo.gameCore.protocol.MessagePool;
+import info.xiaomo.server.protocol.message.gm.ReqCloseServerMessage;
 import info.xiaomo.server.protocol.message.user.ReqLoginMessage;
 
 import java.util.HashMap;
@@ -14,6 +15,7 @@ public class GameMessagePool implements MessagePool {
 
     public GameMessagePool() {
         register(new ReqLoginMessage().getId(), ReqLoginMessage.class);
+        register(new ReqCloseServerMessage().getId(), ReqCloseServerMessage.class);
     }
 
     @Override