From de31e91aa2f38a717f2d4640a3197580ec1807a7 Mon Sep 17 00:00:00 2001
From: 钟日健 <5689795+arsn@user.noreply.gitee.com>
Date: Thu, 19 May 2022 11:23:51 +0800
Subject: [PATCH] 关闭websckot
---
src/main/java/org/springblade/modules/nettyServer/Server.java | 172 ++++++++++++++++++++++++++++----------------------------
1 files changed, 86 insertions(+), 86 deletions(-)
diff --git a/src/main/java/org/springblade/modules/nettyServer/Server.java b/src/main/java/org/springblade/modules/nettyServer/Server.java
index 358aa97..e8c3c51 100644
--- a/src/main/java/org/springblade/modules/nettyServer/Server.java
+++ b/src/main/java/org/springblade/modules/nettyServer/Server.java
@@ -1,86 +1,86 @@
-package org.springblade.modules.nettyServer;
-
-import io.netty.bootstrap.ServerBootstrap;
-import io.netty.channel.*;
-import io.netty.channel.nio.NioEventLoopGroup;
-import io.netty.channel.socket.ServerSocketChannel;
-import io.netty.channel.socket.SocketChannel;
-import io.netty.channel.socket.nio.NioServerSocketChannel;
-
-
-public class Server {
- private int port;
- private ServerSocketChannel serverSocketChannel;
-
- public Server(int port){
- this.port = port;
- bind();
- }
-
- private void bind() {
- Thread thread = new Thread(new Runnable() {
- @Override
- public void run() {
- //服务端要建立两个group，一个负责接收客户端的连接，一个负责处理数据传输
- //连接处理group
- EventLoopGroup boss = new NioEventLoopGroup();
- //事件处理group
- EventLoopGroup worker = new NioEventLoopGroup();
- ServerBootstrap bootstrap = new ServerBootstrap();
- // 绑定处理group
- bootstrap.group(boss, worker).channel(NioServerSocketChannel.class)
- //保持连接数
- .option(ChannelOption.SO_BACKLOG, 1024)
- //有数据立即发送
- .option(ChannelOption.TCP_NODELAY, true)
- //保持连接
- .childOption(ChannelOption.SO_KEEPALIVE, true)
- //处理新连接
- .childHandler(new ChannelInitializer<SocketChannel>() {
- @Override
- protected void initChannel(SocketChannel sc) throws Exception {
- // 增加任务处理
- ChannelPipeline p = sc.pipeline();
- p.addLast(
-// //使用了netty自带的编码器和解码器
-// new StringDecoder(),
-// new StringEncoder(),
- //心跳检测，读超时，写超时，读写超时
- //new IdleStateHandler(5, 0, 0, TimeUnit.SECONDS),
- //自定义的处理器
- new ServerHandler());
- }
- });
-
- //绑定端口，同步等待成功
- ChannelFuture future;
- try {
- future = bootstrap.bind(port).sync();
- if (future.isSuccess()) {
- serverSocketChannel = (ServerSocketChannel) future.channel();
- System.out.println("服务端启动成功，端口："+port);
- } else {
- System.out.println("服务端启动失败！");
- }
-
- //等待服务监听端口关闭,就是由于这里会将线程阻塞，导致无法发送信息，所以我这里开了线程
- future.channel().closeFuture().sync();
- } catch (Exception e) {
- e.printStackTrace();
- }
- finally {
- //优雅地退出，释放线程池资源
- boss.shutdownGracefully();
- worker.shutdownGracefully();
- }
- }
- });
- thread.start();
- }
-
- public void sendMessage(Object msg){
- if(serverSocketChannel != null){
- serverSocketChannel.writeAndFlush(msg);
- }
- }
-}
+//package org.springblade.modules.nettyServer;
+//
+//import io.netty.bootstrap.ServerBootstrap;
+//import io.netty.channel.*;
+//import io.netty.channel.nio.NioEventLoopGroup;
+//import io.netty.channel.socket.ServerSocketChannel;
+//import io.netty.channel.socket.SocketChannel;
+//import io.netty.channel.socket.nio.NioServerSocketChannel;
+//
+//
+//public class Server {
+// private int port;
+// private ServerSocketChannel serverSocketChannel;
+//
+// public Server(int port){
+// this.port = port;
+// bind();
+// }
+//
+// private void bind() {
+// Thread thread = new Thread(new Runnable() {
+// @Override
+// public void run() {
+// //服务端要建立两个group，一个负责接收客户端的连接，一个负责处理数据传输
+// //连接处理group
+// EventLoopGroup boss = new NioEventLoopGroup();
+// //事件处理group
+// EventLoopGroup worker = new NioEventLoopGroup();
+// ServerBootstrap bootstrap = new ServerBootstrap();
+// // 绑定处理group
+// bootstrap.group(boss, worker).channel(NioServerSocketChannel.class)
+// //保持连接数
+// .option(ChannelOption.SO_BACKLOG, 1024)
+// //有数据立即发送
+// .option(ChannelOption.TCP_NODELAY, true)
+// //保持连接
+// .childOption(ChannelOption.SO_KEEPALIVE, true)
+// //处理新连接
+// .childHandler(new ChannelInitializer<SocketChannel>() {
+// @Override
+// protected void initChannel(SocketChannel sc) throws Exception {
+// // 增加任务处理
+// ChannelPipeline p = sc.pipeline();
+// p.addLast(
+//// //使用了netty自带的编码器和解码器
+//// new StringDecoder(),
+//// new StringEncoder(),
+// //心跳检测，读超时，写超时，读写超时
+// //new IdleStateHandler(5, 0, 0, TimeUnit.SECONDS),
+// //自定义的处理器
+// new ServerHandler());
+// }
+// });
+//
+// //绑定端口，同步等待成功
+// ChannelFuture future;
+// try {
+// future = bootstrap.bind(port).sync();
+// if (future.isSuccess()) {
+// serverSocketChannel = (ServerSocketChannel) future.channel();
+// System.out.println("服务端启动成功，端口："+port);
+// } else {
+// System.out.println("服务端启动失败！");
+// }
+//
+// //等待服务监听端口关闭,就是由于这里会将线程阻塞，导致无法发送信息，所以我这里开了线程
+// future.channel().closeFuture().sync();
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
+// finally {
+// //优雅地退出，释放线程池资源
+// boss.shutdownGracefully();
+// worker.shutdownGracefully();
+// }
+// }
+// });
+// thread.start();
+// }
+//
+// public void sendMessage(Object msg){
+// if(serverSocketChannel != null){
+// serverSocketChannel.writeAndFlush(msg);
+// }
+// }
+//}
--
Gitblit v1.9.3