Lanmikeman/Launcher
1
1
Fork 0
mirror of https://github.com/GravitLauncher/Launcher synced 2024-11-15 11:39:11 +03:00
Code Issues Projects Releases Packages Wiki Activity

WebSocketService использование

Browse source
This commit is contained in:
Gravit 2018-10-01 15:11:56 +07:00
parent b42d3d6a08
commit 3daabe584f
2 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
LaunchServer/src/main/java/ru/gravit/launchserver/socket/websocket/WebSocketFrameHandler.java
View file

@ -23,6 +23,7 @@
public class WebSocketFrameHandler extends SimpleChannelInboundHandler<WebSocketFrame> { public class WebSocketFrameHandler extends SimpleChannelInboundHandler<WebSocketFrame> {
public static final ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); public static final ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
public static Gson gson; public static Gson gson;
public WebSocketService service = new WebSocketService(LaunchServer.server,gson);
public static LaunchServer server; public static LaunchServer server;
public static GsonBuilder builder = new GsonBuilder(); public static GsonBuilder builder = new GsonBuilder();
@ -40,9 +41,7 @@ public void channelActive(ChannelHandlerContext ctx) {
protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception { protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {
// ping and pong frames already handled // ping and pong frames already handled
if (frame instanceof TextWebSocketFrame) { if (frame instanceof TextWebSocketFrame) {
String request = ((TextWebSocketFrame) frame).text(); service.process(ctx, (TextWebSocketFrame) frame);
JsonResponse response = gson.fromJson(request, JsonResponse.class);
response.execute(ctx, frame);
} else { } else {
String message = "unsupported frame type: " + frame.getClass().getName(); String message = "unsupported frame type: " + frame.getClass().getName();
throw new UnsupportedOperationException(message); throw new UnsupportedOperationException(message);

1
LaunchServer/src/main/java/ru/gravit/launchserver/socket/websocket/json/EchoResponse.java
View file

@ -22,7 +22,6 @@ public String getType() {
@Override @Override
public void execute(WebSocketService service,ChannelHandlerContext ctx) { public void execute(WebSocketService service,ChannelHandlerContext ctx) {
LogHelper.info("Echo: %s",echo); LogHelper.info("Echo: %s",echo);
ctx.channel().writeAndFlush(new TextWebSocketFrame(WebSocketFrameHandler.gson.toJson(new Result(echo))));
service.sendObject(ctx,new Result(echo)); service.sendObject(ctx,new Result(echo));
} }
public class Result public class Result