。

同时分享案例代码。

项目中用到了log4j2#xff0c;junit5#xff0c;同时分享这些基础组件的使用。

项目中用到了awt讲述Netty的基本使用。

同时分享案例代码。

项目中用到了log4j2junit5同时分享这些基础组件的使用。

项目中用到了awt属于古董技术只是用来做界面。

非重点不用关注。

参考说明

本文内容主要来源于马士兵老师的视频教程Java经典实战项目-坦克大战结合了老师的讲课内容以及自己的实践做了一些补充。

环境说明

xmlnshttp://maven.apache.org/POM/4.0.0

xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0

https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.xxx/groupIdartifactIdxxx/artifactIdversion0.0.1-SNAPSHOT/versionnamexxx/namepropertiesjava.version1.8/java.version/propertiesdependenciesdependencygroupIdcn.hutool/groupIdartifactIdhutool-all/artifactIdversion5.8.21/version/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.28/version/dependency!--

log4j2-slf4j-适配器

--dependencygroupIdorg.apache.logging.log4j/groupIdartifactIdlog4j-slf4j-impl/artifactIdversion2.20.0/version/dependency!--

log4j2

--dependencygroupIdorg.apache.logging.log4j/groupIdartifactIdlog4j-core/artifactIdversion2.20.0/version/dependencydependencygroupIdio.netty/groupIdartifactIdnetty-all/artifactIdversion4.1.96.Final/version/dependency!--

单元测试Junit5

--dependencygroupIdorg.junit.jupiter/groupIdartifactIdjunit-jupiter-engine/artifactIdversion5.9.3/versionscopetest/scope/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build/project日志配置

?xml

自动加载配置文件的间隔时间不低于10秒生产环境中修改配置文件是热更新无需重启应用statusinfo

Configuration

HH:mm:ss.SSS}|%-5level|%-5t|%logger{1.}:

%msg%n/!--

日志格式-打印代码的精确位置信息类方法行。

建议同步使用。

异步如果打印位置信息会有严重性能问题

--property

HH:mm:ss.SSS}|%-5level|%-5t|%location:

%msg%n/!--

nameLOG_HOME${web:rootDir}/WEB-INF/logs/property/properties!--

日志打印输出方式

Pattern${LOG_PATTERN}//ConsoleRollingFile

nameFileLog

fileNamelogs/${PROJECT_NAME}.log

filePatternlogs/${PROJECT_NAME}-%d_%i.logPatternLayout

charsetUTF-8

Pattern${LOG_PATTERN}/Policies!--

--TimeBasedTriggeringPolicy/SizeBasedTriggeringPolicy

size50

MB//PoliciesDefaultRolloverStrategy

max99//RollingFile/Appenders!--

--Loggers!--

dependencygroupIdorg.junit.jupiter/groupIdartifactIdjunit-jupiter-engine/artifactIdversion5.9.3/versionscopetest/scope/dependency新建单元测试类的步骤。

generate

Test然后在弹出的窗口中选择Junit版本为5测试类名测试方法等。

然后点确定。

IDEA会自动根据功能类的路径在test目录中创建相同路径但以Test结尾的测试类。

并且会自动生成勾选方法的默认测试代码。

根据程序的输入和输出编写单元测试代码。

点击方法左边的绿色三角形就可以执行单元测试用例了。

为什么要进行单元测试

方法内部可以很复杂如果靠肉眼观察比较耗时间。

单元测试可以根据入参和返回值测试方法是否达到要求。

代码是开发人员写的最了解代码逻辑的还是开发人员。

测试人员测试不到代码细节。

在一个大的功能中可能会有很多方法每个方法都要写Main方法来一个个测试比较复杂而且也不知道测了哪些场景。

代码业务可能比较简单程序员读代码不是很费力。

写单元测试需要额外花时间程序员工作比较忙没时间写。

功能介绍

简易版聊天室程序。

主要用于练习Netty的使用。

聊天室功能如下

聊天室支持多客户端每个客户端都可以看到其他客户端的消息。

点击关闭按钮时关闭当前客户端同时在服务端的客户端列表中也删除。

系统UI非重点一切从简。

开发步骤

界面包含2个输入部分中间文本域显示当前聊天室的所有聊天内容。

底部文本框输入当前用户的聊天内容

当用户输入完聊天内容后回车需要将聊天内容通过Netty客户端发送给服务端。

当用户关闭窗口时关闭当前客户端同时在服务端的客户端列表中也删除。

/***

ConfigUtil.getInt(chat.frame.width);public

static

ConfigUtil.getInt(chat.frame.height);TextArea

new

{INSTANCE.setVisible(true);ChatClient.connect();}private

ChatFrame()

{//创建游戏的主Framethis.setTitle(chat

GAME_HEIGHT);this.setLocation(800,

100);this.add(ta,

BorderLayout.CENTER);this.add(tf,

BorderLayout.SOUTH);tf.addActionListener(new

ActionListener()

{ChatClient.send(tf.getText());tf.setText();}});this.addWindowListener(new

WindowAdapter()

{ChatClient.close();System.exit(0);}});log.info(chat

room

}编写Netty客户端与服务端进行消息通信(ChatClient.java)。

connect()与服务端建立连接的方法send()向服务端发送聊天消息的方法。

channelRead读取服务端信息更新客户端聊天内容方法参考代码如下

Slf4j

Bootstrap();b.group(group);b.channel(NioSocketChannel.class);b.handler(new

ChannelInitializerSocketChannel()

{Overrideprotected

MyClientHandler());}});ChannelFuture

b.connect(localhost,

8888).sync();//直到服务器被关闭否则一直阻塞。

cf.channel().closeFuture().sync();log.info(the

chat

{log.error(ChatClient.connect.Exception.,

e);}

{group.shutdownGracefully();}}/***

param

{channel.writeAndFlush(Unpooled.copiedBuffer(msg.getBytes()));log.info(client.send().{},

msg);}/***

关闭客户端方法向服务端发送特定消息告知其删除本客户端。

*/public

static

{send(__88__);channel.close();}

}Slf4j

channelRead(ChannelHandlerContext

ctx,

buf.toString(StandardCharsets.UTF_8);ChatFrame.INSTANCE.updateText(text);log.info(channelRead.msg:{},

text);}/***

channelActive(ChannelHandlerContext

ctx)

exceptionCaught(ChannelHandlerContext

ctx,

cause);super.exceptionCaught(ctx,

cause);}

DefaultChannelGroup(GlobalEventExecutor.INSTANCE);public

static

NioEventLoopGroup(1);//接待员线程EventLoopGroup

workerGroup

NioEventLoopGroup(2);//服务器启动辅助类ServerBootstrap

new

ServerBootstrap();//放在第一位的是总管线程组第二位的就是接待员线程组。

b.group(bossGroup,

workerGroup);//异步全双工b.channel(NioServerSocketChannel.class);//接收到客户端连接的处理相当于BIO的acceptb.childHandler(new

ChannelInitializerSocketChannel()

{Overrideprotected

MyChildHandler());}});b.bind(8888).sync();}

}Slf4j

channelActive(ChannelHandlerContext

ctx)

{ChatServer.clients.add(ctx.channel());}/***

param

channelRead(ChannelHandlerContext

ctx,

buf.toString(StandardCharsets.UTF_8);log.info(channelRead().input,string:{},buf:{},

str,

{ChatServer.clients.remove(ctx.channel());ctx.close();log.info(The

chat

{ChatServer.clients.writeAndFlush(msg);log.info(ChatServer.clients.writeAndFlush:{},

msg);}}/***

exceptionCaught(ChannelHandlerContext

ctx,

cause);ChatServer.clients.remove(ctx.channel());ctx.close();}

通知客户端服务器准备关闭。

拒绝新的连接接入等待所有客户端都处理完成。

开始关闭流程发送消息给客户端客户端自动处理。

确认所有客户端断开。

server保存现有的工作数据。

停止线程组退出。

服务端UI

为了可以方便的看到所有客户端的连接情况和消息以及后续进一步实现服务端的关闭效果考虑在服务端实现UI

新增一个ServerFrame类实现服务端UI服务端左边显示消息右边显示客户端的连接情况。

ServerFrame类初始化时自动启动服务端。

服务端接收消息时打印到消息窗口中。

实现效果如下图

ConfigUtil.getInt(server.frame.width);public

static

ConfigUtil.getInt(server.frame.height);TextArea

tmsg

{INSTANCE.setVisible(true);ChatServer.start();}private

ServerFrame()

{//创建游戏的主Framethis.setTitle(chat

GAME_HEIGHT);this.setLocation(100,

Font(Calibri,Font.PLAIN,20));tclient.setFont(new

Font(Calibri,Font.PLAIN,20));Panel

new

2));p.add(tmsg);p.add(tclient);this.add(p);this.addWindowListener(new

WindowAdapter()

{System.exit(0);}});log.info(Server

Main

{tclient.setText(tclient.getText()

text);}

DefaultChannelGroup(GlobalEventExecutor.INSTANCE);public

static

NioEventLoopGroup(1);//接待员线程EventLoopGroup

workerGroup

ServerBootstrap();//放在第一位的是总管线程组第二位的就是接待员线程组。

b.group(bossGroup,

workerGroup);//异步全双工b.channel(NioServerSocketChannel.class);//接收到客户端连接的处理相当于BIO的acceptb.childHandler(new

ChannelInitializerSocketChannel()

{Overrideprotected

MyChildHandler());}});log.info(chat

server

b.bind(8888).sync();cf.channel().closeFuture().sync();}

catch

{log.error(ChatServer.exception,

e);}

{bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();log.info(chat

server

channelActive(ChannelHandlerContext

ctx)

{ServerFrame.INSTANCE.updateClient(client

connected:ctx.channel().remoteAddress());ChatServer.clients.add(ctx.channel());}/***

param

channelRead(ChannelHandlerContext

ctx,

buf.toString(StandardCharsets.UTF_8);log.info(channelRead().input,string:{},buf:{},

str,

{ChatServer.clients.remove(ctx.channel());ctx.close();ServerFrame.INSTANCE.updateClient(client

closedctx.channel().remoteAddress());log.info(The

chat

{ChatServer.clients.writeAndFlush(msg);ServerFrame.INSTANCE.updateMsg(ctx.channel().remoteAddress()

str);log.info(ChatServer.clients.writeAndFlush:{},

msg);}}/***

exceptionCaught(ChannelHandlerContext

ctx,

{log.error(ChatServer.exceptionCaught:,

cause);ChatServer.clients.remove(ctx.channel());ctx.close();}

}启动顺序。

先启动ServerFrame然后启动ChatFrameChatFrame可以启动多个。