From f2b9fa2f8f59a6c562fd009e6bf5484427af868a Mon Sep 17 00:00:00 2001 From: nico Date: Mon, 12 Nov 2018 12:25:11 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E7=AB=AF=E7=9B=91=E6=8E=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/nico/ratel/landlords/server/SimpleServer.java | 3 +++ .../landlords/server/handler/TransferHandler.java | 10 ++++++---- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/landlords-server/src/main/java/org/nico/ratel/landlords/server/SimpleServer.java b/landlords-server/src/main/java/org/nico/ratel/landlords/server/SimpleServer.java index 8733fa9..8f4e02b 100644 --- a/landlords-server/src/main/java/org/nico/ratel/landlords/server/SimpleServer.java +++ b/landlords-server/src/main/java/org/nico/ratel/landlords/server/SimpleServer.java @@ -2,6 +2,7 @@ package org.nico.ratel.landlords.server; import java.net.InetSocketAddress; +import org.nico.ratel.landlords.print.SimplePrinter; import org.nico.ratel.landlords.server.handler.DefaultChannelInitializer; import io.netty.bootstrap.ServerBootstrap; @@ -30,6 +31,8 @@ public class SimpleServer { .childHandler(new DefaultChannelInitializer()); ChannelFuture f = bootstrap .bind().sync(); + + SimplePrinter.printNotice("The server was successfully started on port " + ServerContains.port); f.channel().closeFuture().sync(); } finally { parentGroup.shutdownGracefully(); diff --git a/landlords-server/src/main/java/org/nico/ratel/landlords/server/handler/TransferHandler.java b/landlords-server/src/main/java/org/nico/ratel/landlords/server/handler/TransferHandler.java index f725ca7..7034484 100644 --- a/landlords-server/src/main/java/org/nico/ratel/landlords/server/handler/TransferHandler.java +++ b/landlords-server/src/main/java/org/nico/ratel/landlords/server/handler/TransferHandler.java @@ -25,7 +25,7 @@ public class TransferHandler extends ChannelInboundHandlerAdapter{ ClientSide clientSide = new ClientSide(((InetSocketAddress)ch.remoteAddress()).getPort(), ClientStatus.TO_CHOOSE, ch); clientSide.setNickname(String.valueOf(clientSide.getId())); ServerContains.CLIENT_SIDE_MAP.put(clientSide.getId(), clientSide); - SimplePrinter.printNotice("Has client connects to the server：" + clientSide.getId()); + SimplePrinter.printNotice("Has client connect to the server：" + clientSide.getId()); ChannelUtils.pushToClient(ch, ClientEventCode.CODE_CLIENT_CONNECT, String.valueOf(clientSide.getId())); ChannelUtils.pushToClient(ch, ClientEventCode.CODE_CLIENT_NICKNAME_SET, null); @@ -51,13 +51,15 @@ public class TransferHandler extends ChannelInboundHandlerAdapter{ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { if(cause instanceof java.io.IOException) { - ClientSide client = ServerContains.CLIENT_SIDE_MAP.get(((InetSocketAddress)ctx.channel().remoteAddress()).getPort()); + int clientId = ((InetSocketAddress)ctx.channel().remoteAddress()).getPort(); + ClientSide client = ServerContains.CLIENT_SIDE_MAP.get(clientId); if(client != null) { - SimplePrinter.printNotice(client.getNickname() + " exit"); + SimplePrinter.printNotice("Has client exit to the server：" + clientId + " | " + client.getNickname()); ServerEventListener.get(ServerEventCode.CODE_CLIENT_EXIT).call(client, null); } + }else { + SimplePrinter.printNotice("ERROR：" + cause.getMessage()); } - cause.printStackTrace(); }