39 lines
985 B
Java
39 lines
985 B
Java
package com.bonus.aqd.tcpservice;
|
|
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
/**
|
|
* @author 黑子
|
|
*/
|
|
@Slf4j
|
|
public class NettyServerHandler extends ChannelInboundHandlerAdapter {
|
|
/**
|
|
* 客户端连接会触发
|
|
*/
|
|
@Override
|
|
public void channelActive(ChannelHandlerContext ctx) throws Exception {
|
|
log.info("Channel active......");
|
|
}
|
|
|
|
/**
|
|
* 客户端发消息会触发
|
|
*/
|
|
@Override
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
|
|
log.info("服务器收到消息: {}", msg.toString());
|
|
ctx.write("我是服务端，我收到你的消息了！");
|
|
ctx.flush();
|
|
}
|
|
|
|
/**
|
|
* 发生异常触发
|
|
*/
|
|
@Override
|
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
|
|
cause.printStackTrace();
|
|
ctx.close();
|
|
}
|
|
}
|