1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package io.netty.handler.codec.socksx.v4;
18
19 import io.netty.buffer.ByteBuf;
20 import io.netty.buffer.ByteBufUtil;
21 import io.netty.channel.ChannelHandler.Sharable;
22 import io.netty.channel.ChannelHandlerContext;
23 import io.netty.handler.codec.MessageToByteEncoder;
24 import io.netty.util.NetUtil;
25
26
27
28
29 @Sharable
30 public final class Socks4ServerEncoder extends MessageToByteEncoder<Socks4CommandResponse> {
31
32 public static final Socks4ServerEncoder INSTANCE = new Socks4ServerEncoder();
33
34 private static final byte[] IPv4_HOSTNAME_ZEROED = { 0x00, 0x00, 0x00, 0x00 };
35
36 private Socks4ServerEncoder() {
37 super(Socks4CommandResponse.class);
38 }
39
40 @Override
41 protected void encode(ChannelHandlerContext ctx, Socks4CommandResponse msg, ByteBuf out) throws Exception {
42 out.writeByte(0);
43 out.writeByte(msg.status().byteValue());
44 ByteBufUtil.writeShortBE(out, msg.dstPort());
45 out.writeBytes(msg.dstAddr() == null? IPv4_HOSTNAME_ZEROED
46 : NetUtil.createByteArrayFromIpAddressString(msg.dstAddr()));
47 }
48 }