package com.ld.igds.protocol.beibo.grainv1.client;
|
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.io.api.InvokeResult;
|
import io.netty.bootstrap.Bootstrap;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.*;
|
import io.netty.channel.oio.OioEventLoopGroup;
|
import io.netty.channel.socket.SocketChannel;
|
import io.netty.channel.socket.oio.OioSocketChannel;
|
import io.netty.handler.codec.bytes.ByteArrayDecoder;
|
import io.netty.handler.codec.bytes.ByteArrayEncoder;
|
import io.netty.util.internal.logging.InternalLogger;
|
import io.netty.util.internal.logging.InternalLoggerFactory;
|
|
/**
|
* 贝博粮情协议，分机为服务端，平台为客户端主动连接
|
*
|
* @author czt
|
*/
|
public class BeiboClientEngine implements Runnable {
|
|
private final InternalLogger log = InternalLoggerFactory.getInstance(this.getClass());
|
|
private String host;
|
private int port;
|
// public ChannelFuture channelFuture;
|
public Channel channel;
|
|
public BeiboClientEngine(String host, int port) {
|
this.host = host;
|
this.port = port;
|
}
|
public void start() {
|
Thread thread = new Thread(this);
|
thread.start();
|
}
|
|
@Override
|
public void run() {
|
try {
|
startRun();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
public void startRun() throws Exception {
|
EventLoopGroup group = new OioEventLoopGroup();
|
Bootstrap b = new Bootstrap();
|
// b.option(ChannelOption.SO_KEEPALIVE, true);
|
b.group(group).channel(OioSocketChannel.class)
|
.handler(new ChannelInitializer<SocketChannel>() {
|
@Override
|
protected void initChannel(SocketChannel ch)
|
throws Exception {
|
ChannelPipeline p = ch.pipeline();
|
// 字符串解码和编码
|
p.addLast("decoder", new ByteArrayDecoder());
|
p.addLast("encoder", new ByteArrayEncoder());
|
// 自己的逻辑Handler
|
p.addLast("handler", new ClientHandler());
|
}
|
});
|
|
// 发起异步连接请求，绑定连接端口和host信息
|
ChannelFuture channelFuture = b.connect(host, port);
|
this.channel = channelFuture.channel();
|
// channelFuture.channel().closeFuture().sync();
|
|
channelFuture.addListener(new ChannelFutureListener() {
|
@Override
|
public void operationComplete(ChannelFuture arg0) throws Exception {
|
if (channelFuture.isSuccess()) {
|
log.info("连接服务器成功");
|
} else {
|
log.info("连接服务器失败");
|
channelFuture.cause().printStackTrace();
|
group.shutdownGracefully(); // 关闭线程组
|
}
|
}
|
});
|
}
|
|
public InvokeResult send(byte[] array) throws InterruptedException {
|
if (null == channel) {
|
return InvokeResult.SOCKET_NOT_CREATE;
|
}
|
if (!channel.isActive()) {
|
return InvokeResult.CHANNEL_CLOSED;
|
}
|
channel.writeAndFlush(Unpooled.copiedBuffer(array)).sync();
|
|
return InvokeResult.SUCCESS;
|
}
|
|
public static void main(String[] args) {
|
try {
|
|
String msg = "000000000006010600070012";
|
BeiboClientEngine test = new BeiboClientEngine(
|
"192.168.1.95", 9999);
|
|
test.start();
|
|
msg = "BB BB BB BB";
|
|
// Thread.sleep(3000L);
|
|
test.send(BytesUtil.hexStrToBytes(msg));
|
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
|
public Channel getChannel() {
|
return channel;
|
}
|
|
}
|
