tiennm99/caro
1
0
Fork 0
mirror of https://github.com/tiennm99/caro.git synced 2026-08-24 10:26:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handler client normal exit and abnormal exit situations

Browse Source
This commit is contained in:
nico
2018-11-07 14:55:48 +08:00
parent 845b974ccd
commit d02e424ef3
4 changed files with 97 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
landlords-server/src/main/java/org/nico/ratel/landlords/server/event/ServerEventListener.java
+26
View File
@@ -1,6 +1,10 @@
package org.nico.ratel.landlords.server.event;
import java.util.HashMap;
import java.util.Map;
import org.nico.ratel.landlords.entity.ServerTransferData;
import org.nico.ratel.landlords.enums.ServerEventCode;
import io.netty.channel.Channel;
@@ -8,4 +12,26 @@ public interface ServerEventListener<T> {
public void call(Channel channel, ServerTransferData<T> serverTransferData);
public final static Map<ServerEventCode, ServerEventListener> LISTENER_MAP = new HashMap<>();
final static String LISTENER_PREFIX = "org.nico.ratel.landlords.server.event.ServerEventListener_";
public static ServerEventListener<?> get(ServerEventCode code){
ServerEventListener listener = null;
try {
if(ServerEventListener.LISTENER_MAP.containsKey(code)){
listener = ServerEventListener.LISTENER_MAP.get(code);
}else{
String eventListener = LISTENER_PREFIX + code.name();
Class<ServerEventListener> listenerClass = (Class<ServerEventListener>) Class.forName(eventListener);
listener = listenerClass.newInstance();
ServerEventListener.LISTENER_MAP.put(code, listener);
}
return listener;
}catch(ClassNotFoundException | InstantiationException | IllegalAccessException e) {
e.printStackTrace();
}
return listener;
}
}
landlords-server/src/main/java/org/nico/ratel/landlords/server/event/ServerEventListener_CODE_PLAYER_EXIT.java
+34
View File
@@ -0,0 +1,34 @@
package org.nico.ratel.landlords.server.event;
import org.nico.ratel.landlords.channel.ChannelUtils;
import org.nico.ratel.landlords.entity.ClientSide;
import org.nico.ratel.landlords.entity.Room;
import org.nico.ratel.landlords.entity.ServerTransferData;
import org.nico.ratel.landlords.enums.ClientEventCode;
import org.nico.ratel.landlords.server.ServerContains;
import io.netty.channel.Channel;
public class ServerEventListener_CODE_PLAYER_EXIT implements ServerEventListener<String>{
@Override
public void call(Channel channel, ServerTransferData<String> serverTransferData) {
ClientSide clientSide = ServerContains.CLIENT_SIDE_MAP.get(serverTransferData.getClientId());
Room room = ServerContains.ROOM_MAP.get(clientSide.getRoomId());
if(room != null) {
for(ClientSide client: room.getClientSideList()) {
if(client.getId() != clientSide.getId()) {
ChannelUtils.pushToClient(client.getChannel(), ClientEventCode.CODE_SHOW_OPTIONS, null, clientSide.getNickname() + " exited, room dissolve!!");
}else {
ChannelUtils.pushToClient(client.getChannel(), ClientEventCode.CODE_SHOW_OPTIONS, null, "you exited, room dissolve!!");
}
client.init();
}
}
ServerContains.ROOM_MAP.remove(room.getId());
}
}
landlords-server/src/main/java/org/nico/ratel/landlords/server/handler/DefaultChannelInitializer.java
+1 -4
View File
@@ -7,6 +7,7 @@ import org.nico.ratel.landlords.enums.ClientStatus;
import org.nico.ratel.landlords.print.SimplePrinter;
import org.nico.ratel.landlords.server.ServerContains;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.serialization.ClassResolvers;
@@ -24,10 +25,6 @@ public class DefaultChannelInitializer extends ChannelInitializer<SocketChannel>
ch.pipeline().addLast(new ObjectEncoder());
ch.pipeline().addLast(new TransferHandler());
ClientSide clientSide = new ClientSide(ServerContains.getClientId(), ClientStatus.TO_CHOOSE, ch);
ServerContains.CLIENT_SIDE_MAP.put(clientSide.getId(), clientSide);
SimplePrinter.println("A client connects to the server：" + clientSide.getId());
ChannelUtils.pushToClient(ch, ClientEventCode.CODE_CONNECT, clientSide);
}
}
landlords-server/src/main/java/org/nico/ratel/landlords/server/handler/TransferHandler.java
+36 -9
View File
@@ -1,9 +1,18 @@
package org.nico.ratel.landlords.server.handler;
import java.net.InetSocketAddress;
import org.nico.ratel.landlords.channel.ChannelUtils;
import org.nico.ratel.landlords.entity.ClientSide;
import org.nico.ratel.landlords.entity.ServerTransferData;
import org.nico.ratel.landlords.enums.ClientEventCode;
import org.nico.ratel.landlords.enums.ClientStatus;
import org.nico.ratel.landlords.enums.ServerEventCode;
import org.nico.ratel.landlords.print.SimplePrinter;
import org.nico.ratel.landlords.server.ServerContains;
import org.nico.ratel.landlords.server.event.ServerEventListener;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
@@ -11,6 +20,19 @@ public class TransferHandler extends ChannelInboundHandlerAdapter{
private final static String LISTENER_PREFIX = "org.nico.ratel.landlords.server.event.ServerEventListener_";
@Override
public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
Channel ch = ctx.channel();
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.println("A client connects to the server：" + clientSide.getId());
ChannelUtils.pushToClient(ch, ClientEventCode.CODE_CONNECT, clientSide);
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
@@ -20,18 +42,23 @@ public class TransferHandler extends ChannelInboundHandlerAdapter{
ServerEventCode code = serverTransferData.getCode();
if(code != null) {
String eventListener = LISTENER_PREFIX + code.name();
try {
Class<ServerEventListener> listenerClass = (Class<ServerEventListener>) Class.forName(eventListener);
ServerEventListener listener = listenerClass.newInstance();
listener.call(ctx.channel(), serverTransferData);
}catch(ClassNotFoundException e) {
e.printStackTrace();
}
ServerEventListener.get(code).call(ctx.channel(), serverTransferData);
}
}
}
@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());
if(client != null) {
SimplePrinter.println(client.getNickname() + " exit");
ServerEventListener.get(ServerEventCode.CODE_PLAYER_EXIT).call(ctx.channel(), new ServerTransferData<>(client.getId(), client.getRoomId(), ServerEventCode.CODE_PLAYER_EXIT, null));
}
}
}
}