Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1276844
  • 博文数量: 78
  • 博客积分: 1959
  • 博客等级: 上尉
  • 技术积分: 2709
  • 用 户 组: 普通用户
  • 注册时间: 2007-11-19 12:07
个人简介

樽中酒不空

文章分类

全部博文(78)

文章存档

2024年(2)

2020年(4)

2019年(1)

2017年(2)

2016年(2)

2015年(7)

2014年(11)

2013年(13)

2012年(18)

2011年(2)

2010年(16)

分类: C/C++

2015-07-31 13:47:54


一 准备protobuf环境
1 下载protobuf-2.6.1,解压,进入vsprojects目录,用VC打开工程,编译出 protoc.exe
2 生成.proto文件
message TestMsg 
{
   required string name = 1;
}
放到自己的目录,此例子中放到了f:根目录下。
然后执行:
protoc.exe -I=f:\ --python_out=f:\ f:\TestMsgProto.proto
生成 TestMsgProto_pb2.py,给python用
protoc.exe -I=f:\ --java_out=f:\ f:\TestMsgProto.proto
生成TestMsgProto.java,给java工程用

3 生成对应c++,python,java的class文件

二 python
1 copy protoc.exe到protobuf-2.6.1/python
2 python setup.py build
3 python setup.py install
4 测试用客户端代码:

import google.protobuf
import TestMsgProto_pb2
import socket
address = ('127.0.0.1', 8800)
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(address)
msg = TestMsgProto_pb2.TestMsg()
msg.name='name'
test_str = msg.SerializeToString()
print test_str
ret=s.send(test_str)
print ret
s.close()


三 java环境
可参考: /> 主要看  /> 这下面的几个文件,可以直接放到自己工程里,或者自己稍改动一下。

注意事项:
新建myeclipse maven工程,pom.xml增加:
<dependency>
   <groupId>io.netty</groupId>
   <artifactId>netty-all</artifactId> 
   <version>4.0.30.Final</version>
   <scope>compile</scope>
    </dependency> 
<dependency>
   <groupId>com.google.protobuf</groupId>
   <artifactId>protobuf-java</artifactId>
   <version>2.6.1</version>
</dependency>


然后,主要处理:decoder和encoder,相比gameNettyDemo做了些减化,下面是做过修改的代码:
//NettyMsgEncoder
public class NettyMsgEncoder extends MessageToByteEncoder<String> {
@Override
protected void encode(ChannelHandlerContext ctx, String name, ByteBuf byteBuf) throws Exception {

TestMsgProto.TestMsg.Builder builder = TestMsgProto.TestMsg.newBuilder();
builder.setName(name);

TestMsgProto.TestMsg msg = builder.build();
byteBuf.writeBytes(msg.toByteArray());
}
}


// NettyMsgDecoder
public class NettyMsgDecoder extends LengthFieldBasedFrameDecoder {
//以下两个构造函数,在本例中用不上
public NettyMsgDecoder(ByteOrder byteOrder, int maxFrameLength, int lengthFieldOffset, int lengthFieldLength, int lengthAdjustment, int initialBytesToStrip, boolean failFast) {
super(byteOrder, maxFrameLength, lengthFieldOffset, lengthFieldLength, lengthAdjustment, initialBytesToStrip, failFast);
}

public NettyMsgDecoder() {
this(ByteOrder.BIG_ENDIAN, 100000, 0, 4, 2, 4, true);
}

@Override
protected Object decode(ChannelHandlerContext ctx, ByteBuf byteBuf) throws Exception {
if (byteBuf != null && byteBuf.readableBytes()>0){
int len = byteBuf.readableBytes();
byte[] data = new byte[len];
byteBuf.readBytes(data);
TestMsgProto.TestMsg msg = TestMsgProto.TestMsg.parseFrom(data);


//return msg.getName();
return msg;
}
return null;
}


}


//NettyServerInitializer
public class NettyServerInitializer extends ChannelInitializer<SocketChannel> {


@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast("decoder", new NettyMsgDecoder())// 解码器
.addLast("encoder", new NettyMsgEncoder())// 编码器
.addLast("handler", new ServerHanlder());
}
}
//ServerHanlder
@Sharable
public class ServerHanlder extends SimpleChannelInboundHandler<TestMsgProto.TestMsg> {
@Override
protected void channelRead0(ChannelHandlerContext ctx, TestMsgProto.TestMsg msg)
throws Exception {
if (msg != null)
System.out.println(msg.getName());

}
}

//SimpleChatServer
public class SimpleChatServer {
private int port;


    public SimpleChatServer(int port) {
        this.port = port;
    }


    public void run() throws Exception {


        EventLoopGroup bossGroup = new NioEventLoopGroup(); 
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             //.childHandler(new SimpleChatServerInitializer()) 
             .childHandler(new NettyServerInitializer()) 
             .option(ChannelOption.SO_BACKLOG, 128)         
             .childOption(ChannelOption.SO_KEEPALIVE, true); 


            ChannelFuture f = b.bind(port).sync(); // (7)
            f.channel().closeFuture().sync();


        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();


            System.out.println("SimpleChatServer 关闭了");
        }
    }
}


然后,在Myeclipse里运行java服务器程序
再启动python 远程连接,看接收情况。
从代码上看,小项目用python是多么方便。

上面例子只有java netty的server和python的client .
稍做修改,就能实现python的server和java的client,复杂的依然复杂,简洁的依然简洁。

阅读(4597) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~