package com.hh.common.codec;
import java.net.InetSocketAddress;
import com.hh.common.server.UdpServer;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.socket.DatagramPacket;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class UdpDecoder extends SimpleChannelInboundHandler<DatagramPacket>{
private InetSocketAddress inetAddress;
private Channel ch ;
@Override
protected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg)
throws Exception {
// 接受client的消息
// log.info("开始接收来自client的数据");
final ByteBuf buf = msg.content();
int readableBytes = buf.readableBytes();
byte[] content = new byte[readableBytes];
buf.readBytes(content);
String clientMessage = new String(content,"GBK");
if(clientMessage.contains("UDP_MAIN_CHANNEL_CLIENT")){
inetAddress=msg.sender();
}else{
ctx.writeAndFlush(new DatagramPacket(Unpooled.wrappedBuffer(content),this.inetAddress));
}
log.info("msg recv :{}",clientMessage);
// ch.writeAndFlush(new DatagramPacket(Unpooled.wrappedBuffer(("channel"+ch.id()+":helloClient").getBytes()),msg.sender()));
}
public UdpDecoder() {
super();
}
public UdpDecoder(Channel ch,InetSocketAddress inetAddress) {
super();
this.ch=ch;
this.inetAddress = inetAddress;
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
// TODO Auto-generated method stub
cause.printStackTrace();
super.exceptionCaught(ctx, cause);
}
// /**
// * 发送数据包并监听结果
// * @param datagramPacket
// */
// public static void senderInternal(final DatagramPacket datagramPacket,List<Channel> channelList) {
// for (Channel channel : NettyTCPClient.channelList) {
// if(channel != null){
// channel.writeAndFlush(datagramPacket).addListener(new GenericFutureListener<ChannelFuture>() {
// @Override
// public void operationComplete(ChannelFuture future)
// throws Exception {
// boolean success = future.isSuccess();
// if(logger.isInfoEnabled()){
// logger.info("Sender datagramPacket result : "+success);
// }
// }
// });
// }
// }
// }
//
// /**
// * 组装数据包
// * @param msg 消息串
// * @param inetSocketAddress 服务器地址
// * @return DatagramPacket
// */
// private static DatagramPacket datagramPacket(String msg, InetSocketAddress inetSocketAddress){
// ByteBuf dataBuf = Unpooled.copiedBuffer(msg,Charset.forName("UTF-8"));
// DatagramPacket datagramPacket = new DatagramPacket(dataBuf, inetSocketAddress);
// return datagramPacket;
// }
//
// /**
// * 发送数据包服务器无返回结果
// * @param datagramPacket
// */
// private static void senderInternal(final DatagramPacket datagramPacket) {
// logger.info("LogPushUdpClient.channel"+LogPushUdpClient.channel);
// if(LogPushUdpClient.channel != null){
// LogPushUdpClient.channel.writeAndFlush(datagramPacket).addListener(new GenericFutureListener<ChannelFuture>() {
// @Override
// public void operationComplete(ChannelFuture future)
// throws Exception {
// boolean success = future.isSuccess();
// if(logger.isInfoEnabled()){
// logger.info("Sender datagramPacket result : "+success);
// }
// }
// });
// }else{
// throw new NullPointerException("channel is null");
// }
// }
}
Netty UDP协议网络打洞实例 （129个子文件） 
Connection.class 4KB UdpClient.class 4KB UdpServer.class 3KB TcpClient.class 3KB UdpDecoder.class 3KB TcpClient$ClientHandler.class 3KB TcpServer.class 2KB TcpServer$1.class 2KB MessageDecoder.class 2KB MsgHandler.class 2KB Message.class 2KB App.class 2KB UdpClient$1.class 2KB TcpClient$1.class 2KB UdpServer$1.class 2KB Exchanger.class 1KB MessageEncoder.class 1KB SendingMsg.class 1KB ConnectState.class 1KB App.class 1KB Protocol.class 1KB RandomUtil.class 945B UdpServer$1$1.class 868B ConnectPool.class 782B AppTest.class 643B AppTest.class 643B MsgProto.class 613B UdpServer$UdpServerHolder.class 592B Codec.class 335B Server.class 197B EndPoint.class 116B Client.class 114B .classpath 1KB .classpath 1KB .classpath 1KB .classpath 123B
client.jar 13.02MB transf-server-0.0.1-SNAPSHOT.jar 13.02MB transf-common-0.0.1-SNAPSHOT.jar 29KB UdpDecoder.java 4KB UdpClient.java 3KB TcpClient.java 3KB TcpServer.java 2KB UdpServer.java 2KB App.java 2KB MessageDecoder.java 2KB App.java 1023B Connection.java 853B Exchanger.java 821B MsgHandler.java 821B AppTest.java 679B AppTest.java 679B MessageEncoder.java 673B RandomUtil.java 608B SendingMsg.java 556B ConnectPool.java 374B MsgProto.java 303B Trace.java 243B Message.java 198B Protocol.java 171B Codec.java 140B Server.java 109B ConnectState.java 97B EndPoint.java 65B Client.java 65B info.2019-11-29.log 82.08MB info.2019-12-12.log 748KB info.2019-11-27.log 624KB info.2019-12-12.log 232KB info.2019-11-28.log 198KB info.2019-11-29.log 15KB error.2019-11-27.log 0B error.2019-11-28.log 0B error.2019-11-29.log 0B error.2019-12-12.log 0B error.2019-12-12.log 0B error.2019-11-29.log 0B inputFiles.lst 2KB createdFiles.lst 1KB inputFiles.lst 59B inputFiles.lst 59B createdFiles.lst 17B createdFiles.lst 17B MANIFEST.MF 332B MANIFEST.MF 264B MANIFEST.MF 264B transf-client-0.0.1-SNAPSHOT.jar.original 5KB transf-server-0.0.1-SNAPSHOT.jar.original 4KB org.eclipse.jdt.core.prefs 356B org.eclipse.jdt.core.prefs 356B org.eclipse.jdt.core.prefs 356B org.eclipse.jdt.core.prefs 291B org.eclipse.core.resources.prefs 191B org.eclipse.core.resources.prefs 155B org.eclipse.core.resources.prefs 119B org.eclipse.m2e.core.prefs 90B org.eclipse.m2e.core.prefs 90B org.eclipse.m2e.core.prefs 90B org.eclipse.m2e.core.prefs 90B org.springframework.ide.eclipse.prefs 65B共 129 条
- 1
- 2
资源评论
