From d21890a5f8ecdf9e03148b86c7a272453cd7cae1 Mon Sep 17 00:00:00 2001 From: zhangmeng <1334717033@qq.com> Date: Mon, 27 Feb 2023 14:38:04 +0800 Subject: [PATCH] =?UTF-8?q?netty=20client=202023=E5=B9=B42=E6=9C=8827?= =?UTF-8?q?=E6=97=A514:37:50?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/NettyClientController.java | 161 +++++++++--------- .../com/zhangmeng/tools/netty/Function.java | 14 ++ .../com/zhangmeng/tools/netty/Message.java | 23 +++ .../zhangmeng/tools/netty/NettyClient.java | 161 ++++++++++++++++++ .../zhangmeng/tools/netty/ResponseJson.java | 84 +++++++++ .../tools/netty/WebsocketClientHandler.java | 87 ++++++++++ .../zhangmeng/tools/utils/ExecutorUtils.java | 100 +++++++++++ .../zhangmeng/tools/utils/Multithreading.java | 58 +++++++ src/main/resources/fxml/netty-client.fxml | 5 +- 9 files changed, 612 insertions(+), 81 deletions(-) create mode 100644 src/main/java/com/zhangmeng/tools/netty/Function.java create mode 100644 src/main/java/com/zhangmeng/tools/netty/Message.java create mode 100644 src/main/java/com/zhangmeng/tools/netty/NettyClient.java create mode 100644 src/main/java/com/zhangmeng/tools/netty/ResponseJson.java create mode 100644 src/main/java/com/zhangmeng/tools/netty/WebsocketClientHandler.java create mode 100644 src/main/java/com/zhangmeng/tools/utils/ExecutorUtils.java create mode 100644 src/main/java/com/zhangmeng/tools/utils/Multithreading.java diff --git a/src/main/java/com/zhangmeng/tools/controller/NettyClientController.java b/src/main/java/com/zhangmeng/tools/controller/NettyClientController.java index c11ca7a..2e881d3 100644 --- a/src/main/java/com/zhangmeng/tools/controller/NettyClientController.java +++ b/src/main/java/com/zhangmeng/tools/controller/NettyClientController.java @@ -1,6 +1,10 @@ package com.zhangmeng.tools.controller; +import com.zhangmeng.tools.netty.Message; +import com.zhangmeng.tools.netty.NettyClient; import com.zhangmeng.tools.utils.AlertUtils; +import com.zhangmeng.tools.utils.ExecutorUtils; +import com.zhangmeng.tools.utils.Multithreading; import io.netty.bootstrap.Bootstrap; import io.netty.channel.*; import io.netty.channel.nio.NioEventLoopGroup; @@ -9,7 +13,10 @@ import io.netty.channel.socket.nio.NioSocketChannel; import io.netty.handler.codec.string.StringEncoder; import javafx.application.Platform; import javafx.beans.property.SimpleObjectProperty; +import javafx.beans.value.ChangeListener; +import javafx.beans.value.ObservableValue; import javafx.collections.FXCollections; +import javafx.collections.ListChangeListener; import javafx.collections.ObservableList; import javafx.fxml.FXML; import javafx.geometry.Pos; @@ -20,7 +27,9 @@ import javafx.util.Callback; import javafx.util.StringConverter; import lombok.extern.slf4j.Slf4j; +import java.util.ArrayList; import java.util.Date; +import java.util.List; import java.util.Map; /** @@ -58,9 +67,29 @@ public class NettyClientController { @FXML private Button connect; - private final SimpleObjectProperty client = new SimpleObjectProperty<>(); + @FXML + private TextArea send_msg; - private ObservableList list = FXCollections.observableArrayList(); + private NettyClient nettyClient; + + /** + * 本客户端后台是否已启动 + * + * @since 2021-12-1 + */ + private boolean isStarted; + + private final ObservableList list = FXCollections.observableArrayList(); + private static ObservableList message_result_list = FXCollections.observableArrayList(); + + public static void clear_message(){ + NettyClientController.message_result_list.clear(); + } + + public static void add_message(String msg){ + NettyClientController.message_result_list.add(msg); + NettyClientController.message_result_list.add(System.lineSeparator()); + } private static final int socket_port = 3333; private static final String socket_address = "127.0.0.1"; @@ -91,13 +120,19 @@ public class NettyClientController { } } - public enum Type{ - Ws, - Wss; - } @FXML public void initialize() { + message_result_list.addListener((ListChangeListener) c -> { + if (c.wasAdded()) { + StringBuilder stringBuilder = new StringBuilder(); + for (String s : message_result_list) { + stringBuilder.append(s); + } + receive(stringBuilder.toString()); + } + }); + param_list.setPlaceholder(new Label("没有数据")); param_list.setEditable(true); param_list.setCellFactory(new Callback<>() { @@ -135,28 +170,6 @@ public class NettyClientController { value.setText(null); }); - connect.setOnAction(event -> { - String url = Type.Ws + "://" + url_address.getText() + ":" + port.getText(); - log.info("url:{}",url); - if (client.getValue() == null){ - new Thread(() -> { - netty_client(url_address.getText(),Integer.parseInt(port.getText())); - }).start(); - try { - Thread.sleep(1000); - } catch (InterruptedException e) { - e.printStackTrace(); - } - if (client.getValue() != null){ - AlertUtils.alert_msg("连接成功!"); - }else { - AlertUtils.alert_warning("连接失败!"); - } - }else { - AlertUtils.alert_warning("已连接至服务器!"); - } - }); - if (port.getText().length() == 0) { port.setText(String.valueOf(socket_port)); } @@ -166,62 +179,52 @@ public class NettyClientController { } send.setOnAction(event -> { - Channel channel = client.getValue(); - if (channel == null){ - AlertUtils.alert_warning("请连接至服务器再试!"); - return; + + if (send_msg.getText().length() == 0){ + AlertUtils.alert_warning("请输入内容再试!"); } - channel.writeAndFlush(result_show.getText()); + + String msg = send_msg.getText(); + + Multithreading.execute(() -> { + if (nettyClient == null){ + this.nettyClient = NettyClient.getInstance(); + this.nettyClient.setPort(socket_port); + this.nettyClient.setIp(socket_address); + StringBuilder params = new StringBuilder(); + for (Data data : list) { + if (params.toString().equals("")){ + params.append(data.key).append("=").append(data.value); + }else { + params.append("&").append(data.key).append("=").append(data.value); + } + } + this.nettyClient.setParams(params.toString()); + log.info("params:{}",params.toString()); + } + + // 让客户端后台懒启动。避免先于服务端启动而引发异常 + if (!isStarted) { + this.nettyClient.start(); + isStarted = true; + } + + Platform.runLater(() -> { + this.nettyClient.send(msg); + }); + add_message(msg); + }); + + this.send_msg.requestFocus(); + this.send_msg.clear(); // TODO }); } - private void netty_client(String socket_address,int socket_port) { - log.info("netty client init ......."); - NioEventLoopGroup group = new NioEventLoopGroup(); - try { - Bootstrap bootstrap = new Bootstrap(); - bootstrap.channel(NioSocketChannel.class); - bootstrap.group(group); - bootstrap.handler(new ChannelInitializer() { - @Override - protected void initChannel(SocketChannel ch) throws Exception { - ch.pipeline().addLast("client handler", new ChannelInboundHandlerAdapter() { - // 接收响应消息 - @Override - public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { - log.debug("msg: {}...............", msg); - } - // 在连接建立后触发 active 事件 - @Override - public void channelActive(ChannelHandlerContext ctx) throws Exception { - log.info("channelActive............."); - } + public void receive(String msg) { + Platform.runLater(() -> { + this.result_show.appendText(msg); + }); - @Override - public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { - log.info("exceptionCaught..................."); - } - - @Override - public void channelInactive(ChannelHandlerContext ctx) throws Exception { - log.info("channelInactive..........."); - } - }); - } - }); - Channel channel = bootstrap.connect(socket_address, socket_port).sync().channel(); - client.setValue(channel); - channel.writeAndFlush("1111111111"); - channel.closeFuture().sync(); - } catch (Exception e) { - log.error("client error", e); - } finally { - try { - group.shutdownGracefully().sync(); - } catch (InterruptedException e) { - e.printStackTrace(); - } - } } } diff --git a/src/main/java/com/zhangmeng/tools/netty/Function.java b/src/main/java/com/zhangmeng/tools/netty/Function.java new file mode 100644 index 0000000..9054df7 --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/netty/Function.java @@ -0,0 +1,14 @@ +package com.zhangmeng.tools.netty; + +/** + * @author : 芊芊墨客 + * @version : 1.0 + * @date : 2023-02-27 10:02 + */ +@FunctionalInterface +public interface Function { + /** + * @since 2021-10-3 + */ + void run(); +} diff --git a/src/main/java/com/zhangmeng/tools/netty/Message.java b/src/main/java/com/zhangmeng/tools/netty/Message.java new file mode 100644 index 0000000..49b2771 --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/netty/Message.java @@ -0,0 +1,23 @@ +package com.zhangmeng.tools.netty; + +import java.util.ArrayList; +import java.util.List; + +/** + * @author : 芊芊墨客 + * @version : 1.0 + * @date : 2023-02-27 11:22 + */ +public class Message { + + public static List message_result_list = new ArrayList<>(); + + public static void clear_message(){ + Message.message_result_list.clear(); + } + + public static void add(String msg){ + Message.message_result_list.add(msg); + Message.message_result_list.add(System.lineSeparator()); + } +} diff --git a/src/main/java/com/zhangmeng/tools/netty/NettyClient.java b/src/main/java/com/zhangmeng/tools/netty/NettyClient.java new file mode 100644 index 0000000..11eedd6 --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/netty/NettyClient.java @@ -0,0 +1,161 @@ +package com.zhangmeng.tools.netty; + +import io.netty.bootstrap.Bootstrap; +import io.netty.buffer.PooledByteBufAllocator; +import io.netty.channel.*; +import io.netty.channel.nio.NioEventLoopGroup; +import io.netty.channel.socket.SocketChannel; +import io.netty.channel.socket.nio.NioSocketChannel; +import io.netty.handler.codec.http.DefaultHttpHeaders; +import io.netty.handler.codec.http.HttpClientCodec; +import io.netty.handler.codec.http.HttpObjectAggregator; +import io.netty.handler.codec.http.HttpServerCodec; +import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; +import io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker; +import io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory; +import io.netty.handler.codec.http.websocketx.WebSocketVersion; +import io.netty.handler.stream.ChunkedWriteHandler; +import lombok.extern.slf4j.Slf4j; + +import java.net.URI; +import java.net.URISyntaxException; + +/** + * @author : 芊芊墨客 + * @version : 1.0 + * @date : 2023-02-27 09:15 + */ +@Slf4j +public class NettyClient { + + public enum Type{ + Ws("ws"), + Wss("wss"); + private String name; + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + Type(String name) { + this.name = name; + } + } + + private String serverIp; + + private int serverPort; + + private String params; + + private Channel channel; + + private final EventLoopGroup workerLoopGroup = new NioEventLoopGroup(); + + public void start() { + + WebSocketClientHandshaker handshaker = this.getWebSocketClientHandshaker(); + var businessHandler = new WebsocketClientHandler(handshaker); + Bootstrap bootstrap = new Bootstrap(); + bootstrap.group(workerLoopGroup); + bootstrap.channel(NioSocketChannel.class); + bootstrap.remoteAddress(serverIp, serverPort); + bootstrap.option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT); + bootstrap.handler(new ChannelInitializer() { + @Override + protected void initChannel(SocketChannel ch) { + // HTTP编码解码器 + ch.pipeline().addLast("http-codec", new HttpServerCodec()); + // 把HTTP头、HTTP体拼成完整的HTTP请求 + ch.pipeline().addLast("aggregator", new HttpObjectAggregator(65536)); + // 方便大文件传输，不过实质上都是短的文本数据 + ch.pipeline().addLast("http-chunked", new ChunkedWriteHandler()); + // 定义业务处理器 + ch.pipeline().addLast("businessHandler", businessHandler); + } + }); + + ChannelFuture future = bootstrap.connect(); + future.addListener((ChannelFuture futureListener) -> { + if (futureListener.isSuccess()) { + log.info("客户端连接成功"); + } else { + log.info("客户端连接失败"); + } + }); + try { + future.sync(); + } catch (Exception exception) { + log.info(exception.getMessage()); + } + + this.channel = future.channel(); + handshaker.handshake(channel); + try { + businessHandler.sync(); + } catch (InterruptedException exception) { + log.info(exception.getMessage()); + } + } + + private String generateWebsocketUrl(String ip, int port, String relativePath,String params) { +// return String.format("ws://%s:%d/%s?%s", ip, port, relativePath,params); +// return String.format("ws://%s:%d?%s", ip, port,params); +// return String.format("ws://%s:%d", ip, port); + return String.format("ws://%s:%d/%s", ip, port, relativePath); + } + + public static final String WEBSOCKET_PREFIX_PATH = "websocket"; + + /** + * 进行三报文握手中的第一握手，由客户端发起 + * + * @since 2021-12-2 + */ + private WebSocketClientHandshaker getWebSocketClientHandshaker() { + URI websocketUri = null; + try { +// websocketUri = new URI(this.generateWebsocketUrl(this.serverIp, this.serverPort, WEBSOCKET_PREFIX_PATH,this.params)); + websocketUri = new URI(this.generateWebsocketUrl(this.serverIp, this.serverPort, WEBSOCKET_PREFIX_PATH,null)); + log.info(websocketUri.toString()); + } catch (URISyntaxException exception) { + exception.printStackTrace(); // FIXME：日志 + } + return WebSocketClientHandshakerFactory.newHandshaker(websocketUri, WebSocketVersion.V13, null, false, new DefaultHttpHeaders()); + } + + public void send(String msg) { + channel.writeAndFlush(new TextWebSocketFrame(msg)); + } + + public void destroy() { + this.workerLoopGroup.shutdownGracefully(); + } + + private NettyClient() { + super(); + } + + public static NettyClient getInstance() { + return new NettyClient(); + } + + public NettyClient setIp(String serverIp) { + this.serverIp = serverIp; + return this; + } + + public NettyClient setPort(int serverPort) { + this.serverPort = serverPort; + return this; + } + + public NettyClient setParams(String params){ + this.params = params; + return this; + } +} diff --git a/src/main/java/com/zhangmeng/tools/netty/ResponseJson.java b/src/main/java/com/zhangmeng/tools/netty/ResponseJson.java new file mode 100644 index 0000000..4b9e8b6 --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/netty/ResponseJson.java @@ -0,0 +1,84 @@ +package com.zhangmeng.tools.netty; + +import com.alibaba.fastjson.JSONObject; +import org.springframework.http.HttpStatus; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Set; + +public class ResponseJson extends HashMap { + private static final long serialVersionUID = 1L; + + private static final Integer SUCCESS_STATUS = 200; + private static final Integer ERROR_STATUS = -1; + private static final String SUCCESS_MSG = "一切正常"; + + public ResponseJson() { + super(); + } + + public ResponseJson(int code) { + super(); + setStatus(code); + } + + public ResponseJson(HttpStatus status) { + super(); + setStatus(status.value()); + setMsg(status.getReasonPhrase()); + } + + public ResponseJson success() { + put("msg", SUCCESS_MSG); + put("status", SUCCESS_STATUS); + return this; + } + + public ResponseJson success(String msg) { + put("msg", msg); + put("status", SUCCESS_STATUS); + return this; + } + + public ResponseJson error(String msg) { + put("msg", msg); + put("status", ERROR_STATUS); + return this; + } + + public ResponseJson setData(String key, Object obj) { + @SuppressWarnings("unchecked") + HashMap data = (HashMap) get("data"); + if (data == null) { + data = new HashMap(); + put("data", data); + } + data.put(key, obj); + return this; + } + + public ResponseJson setStatus(int status) { + put("status", status); + return this; + } + + public ResponseJson setMsg(String msg) { + put("msg", msg); + return this; + } + + public ResponseJson setValue(String key, Object val) { + put(key, val); + return this; + } + + /** + * 返回JSON字符串 + */ + @Override + public String toString() { + return JSONObject.toJSONString(this); + } +} diff --git a/src/main/java/com/zhangmeng/tools/netty/WebsocketClientHandler.java b/src/main/java/com/zhangmeng/tools/netty/WebsocketClientHandler.java new file mode 100644 index 0000000..bfc145f --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/netty/WebsocketClientHandler.java @@ -0,0 +1,87 @@ +package com.zhangmeng.tools.netty; + +import com.zhangmeng.tools.controller.NettyClientController; +import io.netty.channel.ChannelFuture; +import io.netty.channel.ChannelHandlerContext; +import io.netty.channel.ChannelInboundHandlerAdapter; +import io.netty.channel.ChannelPromise; +import io.netty.handler.codec.http.FullHttpResponse; +import io.netty.handler.codec.http.websocketx.*; +import io.netty.util.CharsetUtil; +import lombok.extern.slf4j.Slf4j; + +/** + * @author : 芊芊墨客 + * @version : 1.0 + * @date : 2023-02-27 09:20 + */ +@Slf4j +public class WebsocketClientHandler extends ChannelInboundHandlerAdapter { + + private WebSocketClientHandshaker handshaker; + + private ChannelPromise channelPromise; + + public WebsocketClientHandler(WebSocketClientHandshaker handshaker) { + this.handshaker = handshaker; + } + + @Override + public void channelRead(ChannelHandlerContext ctx, Object obj) { + if (!this.handshaker.isHandshakeComplete()) { // 如果三报文握手的流程还没有走完 + // 如果现在进行的是三报文握手中的第三握手 + finishHandshake(ctx, (FullHttpResponse) obj); + } else if (obj instanceof FullHttpResponse response) { + var msg = String.format("Unexpected FullHttpResponse, status=%s, content=%s", response.status(), response.content().toString(CharsetUtil.UTF_8)); + System.out.println(msg); // FIXME：日志 + } else if (obj instanceof WebSocketFrame) { + // TODO：如果需要服务器反馈信息，可在此添加业务 + handleWebSocketResponse(ctx, (WebSocketFrame) obj); + } // 此分支不应该发生 + + } + + @Override + public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { + ctx.close(); + } + + @Override + public void handlerAdded(ChannelHandlerContext ctx) { + this.channelPromise = ctx.newPromise(); + } + + public ChannelFuture sync() throws InterruptedException { + return this.channelPromise.sync(); + } + + private void finishHandshake(ChannelHandlerContext ctx, FullHttpResponse response) { + try { + this.handshaker.finishHandshake(ctx.channel(), response); + //设置成功 + this.channelPromise.setSuccess(); + } catch (WebSocketHandshakeException exception) { + FullHttpResponse rsp = response; + String errorMsg = String.format("WebSocket Client failed to connect, status=%s, reason=%s", rsp.status(), rsp.content().toString(CharsetUtil.UTF_8)); + this.channelPromise.setFailure(new Exception(errorMsg)); // TODO：日志 + } + } + + private void handleWebSocketResponse(ChannelHandlerContext ctx, WebSocketFrame frame) { + + // 关闭请求 + if (frame instanceof CloseWebSocketFrame) { + handshaker.close(ctx.channel(), (CloseWebSocketFrame) frame.retain()); + return; + } + + // ping请求 + if (frame instanceof PingWebSocketFrame) { + ctx.channel().write(new PongWebSocketFrame(frame.content().retain())); + return; + } + String text = ((TextWebSocketFrame) frame).text(); + log.info("text:{}", text); + NettyClientController.add_message(text); + } +} \ No newline at end of file diff --git a/src/main/java/com/zhangmeng/tools/utils/ExecutorUtils.java b/src/main/java/com/zhangmeng/tools/utils/ExecutorUtils.java new file mode 100644 index 0000000..a49d668 --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/utils/ExecutorUtils.java @@ -0,0 +1,100 @@ +package com.zhangmeng.tools.utils; + +import javafx.concurrent.Task; + +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; + +/** + * @author : 芊芊墨客 + * @version : 1.0 + * @date : 2023-02-27 09:57 + */ +public class ExecutorUtils { + + /** + * 这里凡是使用 volatile 的变量都使用了单例模式中的“双重检查锁定” + */ + + /** + * 注意：记得在程序结束时，如果 executor 不为 null， 使用 “executor.shutdown();” 来回收资源 + * + * @since 2021-9-28 + */ + private static volatile ExecutorService executor; + private static final Object EXECUTOR_LOCK = new Object(); + + /** + * 注意：记得在程序结束时，如果 tasks 不为 null，对于每一个 task，使用 “task.cancel();” 来回收资源 + * + * @since 2021-9-28 + */ + private static volatile List> tasks; + private static final Object TASKS_LOCK = new Object(); + + /** + * 提供此方法是为了进行“懒加载” + * + * 这里使用了单例模式中的“双重检查锁定” + * + * @since 2021-9-28 + */ + public static ExecutorService getExecutor() { + // 第一重判断 + if (ExecutorUtils.executor == null) { + // 上锁 + synchronized (EXECUTOR_LOCK) { + // 第二重判断 + if (ExecutorUtils.executor == null) { + // 设置初始线程个数，大致为 6 + ExecutorUtils.executor = Executors.newFixedThreadPool(6); + } + } + } + return ExecutorUtils.executor; + } + + /** + * 提供此方法是为了进行“懒加载” + * + * @since 2021-9-28 + */ + public static List> getTasks() { + // 第一重判断 + if (ExecutorUtils.tasks == null) { + // 上锁 + synchronized (TASKS_LOCK) { + // 第二重判断 + if (ExecutorUtils.tasks == null) { + ExecutorUtils.tasks = new ArrayList<>(); + } + } + } + + return ExecutorUtils.tasks; + } + + /** + * 记得在打算关闭应用时调用此方法。 + * 不能在应用正在运行时调用此方法 + * + * 作用：回收本类所有关于多线程的资源 + * + * @since 2021-9-28 + */ + public static void multithreadingClosed() { + if (ExecutorUtils.tasks != null) { + for (var task : ExecutorUtils.tasks) { + if (!task.isDone()) { + task.cancel(); + } + } + } + + if (ExecutorUtils.executor != null) { + ExecutorUtils.executor.shutdown(); + } + } +} diff --git a/src/main/java/com/zhangmeng/tools/utils/Multithreading.java b/src/main/java/com/zhangmeng/tools/utils/Multithreading.java new file mode 100644 index 0000000..eff0284 --- /dev/null +++ b/src/main/java/com/zhangmeng/tools/utils/Multithreading.java @@ -0,0 +1,58 @@ +package com.zhangmeng.tools.utils; + +import java.util.concurrent.Future; + +import com.zhangmeng.tools.netty.Function; +import javafx.concurrent.Task; + + +/** + * @author : 芊芊墨客 + * @version : 1.0 + * @date : 2023-02-27 10:00 + */ +public class Multithreading { + + /** + * 无结果反馈的版本 + * + * @since 2021-10-3 + * @lastModified 2021-10-10 + */ + public static void execute(Function function) { + /** + * 开新线程来完成下面的操作 + */ + Task task = new Task<>() { + @Override + protected Integer call() { + function.run(); + return null; // 因为此处不需要结果反馈，所以返回 null + } + }; + ExecutorUtils.getTasks().add(task); + ExecutorUtils.getExecutor().execute(task); + } + + /** + * 有结果反馈的版本 + * + * @since 2021-10-10 + */ + public static Future submit(Function function) { + + /** + * 开新线程来完成下面的操作 + */ + Task task = new Task<>() { + @Override + protected Object call() { + function.run(); + return null; // 因为此处暂时没定好应该反馈什么东西，所以返回 null + } + }; + ExecutorUtils.getTasks().add(task); + return ExecutorUtils.getExecutor().submit(task); + } + +} diff --git a/src/main/resources/fxml/netty-client.fxml b/src/main/resources/fxml/netty-client.fxml index 6486620..210e1b9 100644 --- a/src/main/resources/fxml/netty-client.fxml +++ b/src/main/resources/fxml/netty-client.fxml @@ -21,9 +21,10 @@