java tcp 报文_java使用TCP协议传输报文，服务器端

小鱼儿 2022-11-03 11:37 31阅读 0赞

首先是main方法

package org.fiberhome.action;

import io.netty.bootstrap.ServerBootstrap;

import io.netty.channel.ChannelFuture;

import io.netty.channel.ChannelOption;

import io.netty.channel.EventLoopGroup;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.nio.NioServerSocketChannel;

import org.fiberhome.service.ServerChannelInitializer;

import org.fiberhome.utils.TcpServiceConfig;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/\*\*

\* 服务器启动逻辑

\*/

public class MainAction \{

public static void main(String\[\] args) throws Exception \{

int port = TcpServiceConfig.tcpPort;

if (args != null && args.length > 0) \{

try \{

port = Integer.valueOf(args\[0\]);

\} catch (NumberFormatException e) \{

//采用默认值

new MainAction().bind(port);

public void bind(int port) throws Exception \{

Logger log = LoggerFactory.getLogger(MainAction.class);

//配置服务端的NIO线程组

EventLoopGroup bossGroup = new NioEventLoopGroup();

EventLoopGroup workerGroup = new NioEventLoopGroup();

try \{

ServerBootstrap b = new ServerBootstrap();

b.group(bossGroup, workerGroup)

.channel(NioServerSocketChannel.class)

.option(ChannelOption.SO\_BACKLOG, TcpServiceConfig.backlog)

.childHandler(new ServerChannelInitializer());

//绑定端口，同步等待成功

ChannelFuture f = b.bind(port).sync();

log.info("服务已启动===========等待连接！！！");

//等待服务器监听端口关闭;

f.channel().closeFuture().sync();

\} finally \{

//优雅退出，释放线程池资源

bossGroup.shutdownGracefully();

workerGroup.shutdownGracefully();

服务器Channel通道初始化设置：

package org.fiberhome.service;

import io.netty.channel.ChannelInitializer;

import io.netty.channel.ChannelPipeline;

import io.netty.channel.socket.SocketChannel;

import io.netty.handler.codec.string.StringDecoder;

import io.netty.handler.codec.string.StringEncoder;

/\*\*

\* 服务器Channel通道初始化设置

\*/

public class ServerChannelInitializer extends ChannelInitializer\{

@Override

protected void initChannel(SocketChannel socketChannel) throws Exception \{

ChannelPipeline pipeline = socketChannel.pipeline();

//字符串解码和编码

pipeline.addLast("decoder", new StringDecoder());

pipeline.addLast("encoder", new StringEncoder());

//服务器的逻辑

pipeline.addLast("handler", new TcpServerHandler());

服务器业务逻辑：

package org.fiberhome.service;

import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.SimpleChannelInboundHandler;

import org.fiberhome.service.impl.TcpServiceImpl;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/\*\*

\* 服务器业务逻辑

\*/

public class TcpServerHandler extends SimpleChannelInboundHandler \{

Logger log = LoggerFactory.getLogger(TcpServerHandler.class);

// @Autowired

// private TcpService tcpService;

@Override

protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception \{

String data= msg.toString();

// System.out.println("Client say : " + msg.toString());

//返回客户端消息 - 我已经接收到了你的消息

ctx.writeAndFlush("Successful reception!");

try \{

new TcpServiceImpl().insertWarning(data);

\}catch (Exception e)\{

log.error("报文格式不合格！！！");

@Override

public void channelActive(ChannelHandlerContext ctx) throws Exception \{

log.info("RemoteAddress : " + ctx.channel().remoteAddress() + " active !");

ctx.writeAndFlush("Successful connection!");

super.channelActive(ctx);

java tcp 报文_java使用TCP协议传输报文，服务器端

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关传输层协议（1）：TCP 报文结构

相关浅析TCP协议报文生成过程

相关 Java. tcp报文长度_tcp，udp报文最大长度

相关 java tcp 报文_java使用TCP协议传输报文，服务器端

相关 TCP协议学习笔记、报文分析

相关 TCP报文格式

相关 TCP报文发送工具

相关 TCP协议-RST报文

相关 TCP报文格式详解

相关使用wireshark分析tcp报文