- 浏览: 537943 次
- 性别:
- 来自: 北京
-
文章分类
最新评论
-
landerson：
明显就有要求的嘛
ANDROID轻量级JSON序列化和反序列化［转］ -
jimode2013：
很不错，就是需要这个方法
多个UIViewController使用addSubView，第二个 UIViewController 不响应旋转[转] -
w11h22j33：
...
［转］NSMutableArray中的自动释放对象让我郁闷了一整天 -
w11h22j33：
UILabel* label = [[UILabel a ...
Iphone开发 -
w11h22j33：
http://mobile.51cto.com/iphone- ...
获得通讯录中联系人的所有属性［转］
protobuf 是什么？ 参考文档 http://code.google.com/intl/zh-CN/apis/protocolbuffers/docs/overview.html protobuf 适用的语言 正宗（Google 自己内部用的）的protobuf支持三种语言：Java 、c++和Pyton，很遗憾的是并不支持.Net 或者 Lua 等语言，但社区的力量是不容忽视的，由于protobuf确实比Json、XML有速度上的优势和使用的方便，并且可以做到向前兼容、向后兼容等众多特点，所以protobuf社区又弄了个protobuf.net的组件并且还支持众多语言，详细可以看这个链接：http://code.google.com/p/protobuf/wiki/ThirdPartyAddOns，具体某种语言的使用请各自对号入座，本篇只是讲使用android 与c++服务器通讯（测试过）或者与PC 通讯，使用java与C#之间互相通讯方面的DEMO，方面读者做参考。 定义protobuf协议 定义protobuf协议必须创建一个以.proto为后缀的文件，以本篇为例，本篇创建了一个叫msg.proto的消息文件，内容如下： } package在Java里面代表这个文件所在的包名，在c#里面代表该文件的命名空间，message代表一个类， 如何编译该proto文件 java或android 使用的编译方法 正宗的proto可以在Linux下编译也有提供win版编译，由于Linux下编译要配置什么g++呀，之类的有点麻烦，之前做的步骤都忘得差不多，那还是回到win版编译吧，而net 版则是需要在win版下编译。 正宗google 的protobuf 下载列表请参照：http://code.google.com/p/protobuf/downloads/list ，选择其中的win版本下载。解压后会得到一个protoc.exe 文件，此时就可以开始编译了，先以java 为例，编译的步骤如下： .net 版的protobuf来源于proto社区，有两个版本。一个版本叫protobuf-net，官方站点：http://code.google.com/p/protobuf-net/ 写法上比较符合c#一贯的写法。另一个版本叫protobuf-csharp-sport ， 进入该站点，下载你要的win版。 编译步骤如下： 将其另存为.bat文件即可 android 与PC android 做为客户端向PC的Java服务端发送数据，服务端得到数据进行解析，并打印出来 。 客户端代码： } 服务端代码： package server; 最后得到的效果： 客户端： 服务端： protobuf .net版的实现代码如下： } 运行的效果： 这样就OK了，之后就可以把java 服务端的IP或端口改成C# IP和服务端的商品一样，或者反过来也是可以的。c++版本经过测试也是可以的。简直是一个爽字。
使用protobuf协议
message CMsg
{
required string msghead = 1;
required string msgbody = 2;
}
message CMsgHead
{
required int32 msglen = 1;
required int32 msgtype = 2;
required int32 msgseq = 3;
required int32 termversion = 4;
required int32 msgres = 5;
required string termid = 6;
}
message CMsgReg
{
optional int32 area = 1;
optional int32 region = 2;
optional int32 shop = 3;
optional int32 ret = 4;
optional string termid = 5[defalut="12345"];
}
message CMsgLogin
{
optional int32 ret = 1;
}
message CMsgLogout
{
optional int32 ret = 1;
protoc --descriptor_set_out=msg.protobin --include_imports msg.proto 使用protobuf编译后的文件来进行socket连接
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import socket.exception.SmsClientException;
import socket.exception.SmsObjException;
import msginfo.Msg.CMsg;
import msginfo.Msg.CMsgHead;
import msginfo.Msg.CMsgReg;
import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import com.google.protobuf.InvalidProtocolBufferException;
//客户端的实现
public class TestSocket extends Activity {
private TextView text1;
private Button but1;
Socket socket = null;
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
// Thread desktopServerThread=new Thread(new AndroidServer());
// desktopServerThread.start();
setContentView(R.layout.main);
text1 = (TextView) findViewById(R.id.text1);
but1 = (Button) findViewById(R.id.but1);
but1.setOnClickListener(new Button.OnClickListener() {
@Override
public void onClick(View v) {
// edit1.setText("");
// Log.e("dddd", "sent id");
// new Thread() {
// public void run() {
try {
// socket=new Socket("192.168.1.102",54321);
//socket = new Socket("192.168.1.110", 10527);
socket = new Socket("192.168.1.116", 12345);
//得到发送消息的对象
//SmsObj smsobj = new SmsObj(socket);
//设置消息头和消息体并存入消息里面
// head
CMsgHead head = CMsgHead.newBuilder().setMsglen(5)
.setMsgtype(1).setMsgseq(3).setTermversion(41)
.setMsgres(5).setTermid("11111111").build();
// body
CMsgReg body = CMsgReg.newBuilder().setArea(22)
.setRegion(33).setShop(44).build();
// Msg
CMsg msg = CMsg.newBuilder()
.setMsghead(head.toByteString().toStringUtf8())
.setMsgbody(body.toByteString().toStringUtf8())
.build();
// PrintWriter out = new PrintWriter(new BufferedWriter(
// new OutputStreamWriter(socket.getOutputStream())),
// true);
// out.println(m.toString());
// out.println(m.toByteString().toStringUtf8());
// 向服务器发送信息
msg.writeTo(socket.getOutputStream());
//byte[] b = msg.toByteArray();
//smsobj.sendMsg(b);
// System.out.println("====msg==="
// + m.toByteString().toStringUtf8());
// byte[] backBytes = smsobj.recvMsg();
//
// 接受服务器的信息
InputStream input = socket.getInputStream();
// DataInputStream dataInput=new DataInputStream();
//byte[] by = smsobj.recvMsg(input);
byte[] by=recvMsg(input);
setText(CMsg.parseFrom(by));
// BufferedReader br = new BufferedReader(
// new InputStreamReader(socket.getInputStream()));
// String mstr = br.readLine();
// if (!str .equals("")) {
// text1.setText(str);
// } else {
// text1.setText("数据错误");
// }
// out.close();
// br.close();
input.close();
//smsobj.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
System.out.println(e.toString());
}
// };
// }.start();
}
});
}
/**
* 接收server的信息
*
* @return
* @throws SmsClientException
* @author fisher
*/
public byte[] recvMsg(InputStream inpustream) throws SmsObjException {
try {
byte len[] = new byte[1024];
int count = inpustream.read(len);
byte[] temp = new byte[count];
for (int i = 0; i < count; i++) {
temp[i] = len[i];
}
return temp;
} catch (Exception localException) {
throw new SmsObjException("SmapObj.recvMsg() occur exception!"
+ localException.toString());
}
}
/**
* 得到返回值添加到文本里面
*
* @param g
* @throws InvalidProtocolBufferException
*/
public void setText(CMsg g) throws InvalidProtocolBufferException {
CMsgHead h = CMsgHead.parseFrom(g.getMsghead().getBytes());
StringBuffer sb = new StringBuffer();
if (h.hasMsglen())
sb.append("==len===" + h.getMsglen() + "\n");
if (h.hasMsgres())
sb.append("==res===" + h.getMsgres() + "\n");
if (h.hasMsgseq())
sb.append("==seq===" + h.getMsgseq() + "\n");
if (h.hasMsgtype())
sb.append("==type===" + h.getMsgtype() + "\n");
if (h.hasTermid())
sb.append("==Termid===" + h.getTermid() + "\n");
if (h.hasTermversion())
sb.append("==Termversion===" + h.getTermversion() + "\n");
CMsgReg bo = CMsgReg.parseFrom(g.getMsgbody().getBytes());
if (bo.hasArea())
sb.append("==area==" + bo.getArea() + "\n");
if (bo.hasRegion())
sb.append("==Region==" + bo.getRegion() + "\n");
if (bo.hasShop())
sb.append("==shop==" + bo.getShop() + "\n");
if (bo.hasRet())
sb.append("==Ret==" + bo.getRet() + "\n");
if (bo.hasTermid())
sb.append("==Termid==" + bo.getTermid() + "\n");
text1.setText(sb.toString());
}
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import msginfo.Msg.CMsg;
import msginfo.Msg.CMsgHead;
import msginfo.Msg.CMsgReg;
public class AndroidServer implements Runnable {
public void run() {
try {
System.out.println("beign:");
ServerSocket serverSocket = new ServerSocket(12345);
while (true) {
System.out.println("等待接收用户连接：");
// 接受客户端请求
Socket client = serverSocket.accept();
DataOutputStream dataOutputStream;
DataInputStream dataInputStream;
try {
// 接受客户端信息
// BufferedReader in = new BufferedReader(
// new InputStreamReader(client.getInputStream()));
// String str = in.readLine();
// System.out.println("read length: " + str.length());
// System.out.println("read: " + str);
// InputStream inputstream = client.getInputStream();
// byte[] buffer = new byte[1024 * 4];
// int temp = 0;
// while ((temp = inputstream.read(buffer)) != -1) {
// str = new String(buffer, 0, temp);
// System.out.println("===str===" + str);
// File file = new File("user\\log\\login.log");
// appendLog(file, str);
InputStream inputstream = client.getInputStream();
dataOutputStream = new DataOutputStream(
client.getOutputStream());
//dataInputStream = new DataInputStream(inputstream);
// byte[] d = new BufferedReader(new InputStreamReader(
// dataInputStream)).readLine().getBytes();
// byte[] bufHeader = new byte[4];
// dataInputStream.readFully(bufHeader);
// int len = BytesUtil.Bytes4ToInt(bufHeader);
// System.out.println(d.length);
// System.out.println(dataInputStream.readLine().toString());
byte len[] = new byte[1024];
int count = inputstream.read(len);
byte[] temp = new byte[count];
for (int i = 0; i < count; i++) {
temp[i] = len[i];
}
// 协议正文
// byte[] sendByte = new byte[30];
//
// dataInputStream.readFully(sendByte);
// for (byte b : sendByte) {
// System.out.println(""+b);
// }
CMsg msg = CMsg.parseFrom(temp);
//
//
CMsgHead head = CMsgHead.parseFrom(msg.getMsghead()
.getBytes());
System.out.println("==len===" + head.getMsglen());
System.out.println("==res===" + head.getMsgres());
System.out.println("==seq===" + head.getMsgseq());
System.out.println("==type===" + head.getMsgtype());
System.out.println("==Termid===" + head.getTermid());
System.out.println("==Termversion==="
+ head.getTermversion());
CMsgReg body = CMsgReg.parseFrom(msg.getMsgbody()
.getBytes());
System.out.println("==area==" + body.getArea());
System.out.println("==Region==" + body.getRegion());
System.out.println("==shop==" + body.getShop());
// PrintWriter out = new PrintWriter(new BufferedWriter(
// new OutputStreamWriter(client.getOutputStream())),
// true);
// out.println("return " +msg.toString());
// in.close();
// out.close();
sendProtoBufBack(dataOutputStream);
inputstream.close();
//dataInputStream.close();
} catch (Exception ex) {
System.out.println(ex.getMessage());
ex.printStackTrace();
} finally {
client.close();
System.out.println("close");
}
}
} catch (IOException e) {
System.out.println(e.getMessage());
}
}
public static void main(String[] args) {
Thread desktopServerThread = new Thread(new AndroidServer());
desktopServerThread.start();
}
private byte[] getProtoBufBack() {
// head
CMsgHead head = CMsgHead.newBuilder().setMsglen(5)
.setMsgtype(1).setMsgseq(3).setTermversion(41)
.setMsgres(5).setTermid("11111111").build();
// body
CMsgReg body = CMsgReg.newBuilder().setArea(22)
.setRegion(33).setShop(44).build();
// Msg
CMsg msg = CMsg.newBuilder()
.setMsghead(head.toByteString().toStringUtf8())
.setMsgbody(body.toByteString().toStringUtf8())
.build();
return msg.toByteArray();
}
private void sendProtoBufBack(DataOutputStream dataOutputStream) {
byte[] backBytes = getProtoBufBack();
// 协议头部
// Integer len2 = backBytes.length;
// 前四个字节，标示协议正文长度
// byte[] cmdHead2 = BytesUtil.IntToBytes4(len2);
try {
//dataOutputStream.write(cmdHead2, 0, cmdHead2.length);
dataOutputStream.write(backBytes, 0, backBytes.length);
dataOutputStream.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
}
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using Google.ProtocolBuffers;
using msginfo;
using System.Text;
using System.Collections;
using System.Collections.Generic;
namespace protobuf_csharp_sport
{
class Program
{
private static ManualResetEvent allDone = new ManualResetEvent(false);
static void Main(string[] args)
{
beginProtocbuf();
}
private static void beginProtocbuf()
{
//启动服务端
TcpListener server = new TcpListener(IPAddress.Parse("127.0.0.1"), 12345);
server.Start();
server.BeginAcceptTcpClient(clientConnected, server);
Console.WriteLine("SERVER : 等待数据 ---");
//启动客户端
ThreadPool.QueueUserWorkItem(runClient);
allDone.WaitOne();
Console.WriteLine("SERVER : 退出 ---");
// server.Stop();
}
//服务端处理
private static void clientConnected(IAsyncResult result)
{
try
{
TcpListener server = (TcpListener)result.AsyncState;
using (TcpClient client = server.EndAcceptTcpClient(result))
{
using (NetworkStream stream = client.GetStream())
{
//获取
Console.WriteLine("SERVER : 客户端已连接，数据读取中 --- ");
byte[] myRequestBuffer = new byte[1024];
int myRequestLength = 0;
do
{
myRequestLength = stream.Read(myRequestBuffer, 0, myRequestBuffer.Length);
}
while (stream.DataAvailable);
CMsg msg = CMsg.ParseFrom(myRequestBuffer.RemoveEmptyByte(myRequestLength));
CMsgHead head = CMsgHead.ParseFrom(Encoding.ASCII.GetBytes(msg.Msghead));
CMsgReg body = CMsgReg.ParseFrom(Encoding.ASCII.GetBytes(msg.Msgbody));
IDictionary<Google.ProtocolBuffers.Descriptors.FieldDescriptor, object> d = head.AllFields;
foreach (var item in d)
{
Console.WriteLine(item.Value.ToString());
}
d = body.AllFields;
Console.WriteLine("===========================================");
foreach (var item in d)
{
Console.WriteLine(item.Value.ToString());
}
Console.WriteLine("SERVER : 响应成功 ---");
Console.WriteLine("SERVER: 关闭连接 ---");
stream.Close();
}
client.Close();
}
}
finally
{
allDone.Set();
}
}
//客户端请求
private static void runClient(object state)
{
try
{
CMsgHead head = CMsgHead.CreateBuilder()
.SetMsglen(5)
.SetMsgtype(1)
.SetMsgseq(3)
.SetTermversion(4)
.SetMsgres(5)
.SetTermid("11111111")
.Build();
CMsgReg body = CMsgReg.CreateBuilder().
SetArea(22)
.SetRegion(33)
.SetShop(44)
.Build();
CMsg msg = CMsg.CreateBuilder()
.SetMsghead(head.ToByteString().ToStringUtf8())
.SetMsgbody(body.ToByteString().ToStringUtf8())
.Build();
Console.WriteLine("CLIENT : 对象构造完毕 ...");
using (TcpClient client = new TcpClient())
{
// client.Connect(new IPEndPoint(IPAddress.Parse("192.168.1.116"), 12345));
client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 12345));
Console.WriteLine("CLIENT : socket 连接成功 ...");
using (NetworkStream stream = client.GetStream())
{
//发送
Console.WriteLine("CLIENT : 发送数据 ...");
msg.WriteTo(stream);
//关闭
stream.Close();
}
client.Close();
Console.WriteLine("CLIENT : 关闭 ...");
}
}
catch (Exception error)
{
Console.WriteLine("CLIENT ERROR : {0}", error.ToString());
}
}
}//end class
public static class ExtensionClass {
public static byte[] RemoveEmptyByte(this byte[] by,int length)
{
byte[] returnByte = new byte[length];
for (int i = 0; i < length; i++)
{
returnByte[i] = by[i];
}
return returnByte;
}
}
发表评论
-
思考、学习新技术的原则和方式【转】
2014-01-02 17:50 1107http://kb.cnblogs.com/page/195 ... -
最好的程序员凡事先上谷歌搜索【转】
2013-03-07 18:07 1297我知道的最优秀的程序员是我的Framebase.io ... -
史上最最佳软件开发实践指导【转】
2013-03-07 18:06 1260“” 阅读器 软件开发 -
我所钟爱的代码审查【转】
2013-02-22 18:00 927当我从学术界转向产业界的过程中，对我生涯改变最大的事情就 ... -
高效代码审查的十个经验【转】
2013-02-22 17:59 976代码审查（Code Review)是软件开发中常用的手段，和 ... -
为什么程序员不擅长评估开发时间？[转]
2012-12-17 10:07 850一个曾经与我一起工作过的经验丰富的项目经理声称，他拿到程 ... -
给明年依然年轻的我们［转］
2012-06-28 09:18 930今天是22岁的最后一天。几个月前，我从沃顿商学院毕业，用 ... -
[转]用户交互设计UI参考书目整理
2012-01-19 15:18 1149书名 作者用户体验的要素 Jesse James Garret ... -
【转】开源点评：Protocol Buffers介绍
2011-09-07 17:14 1172引自：http://blog.csdn.net/p ... -
google ProtoBuf开发者指南【转】
2011-09-07 17:09 2503目录 1 概览 1.1 什么是 ... -
hg clone 命令的windows解决方法TortoiseHg[转]
2011-05-11 20:50 2330hg是跟svn和cvs一样的版本管理系统。windows下 ... -
谷歌高效能经理人的8个习惯【转】
2011-03-26 12:24 1198Google's "people operati ... -
面试时不要说的7件事【转】
2011-03-26 11:55 9857 Things Not to Say During ... -
为了成功 训练自己[转]
2011-03-26 11:50 1291你是否曾见过像曼尼· ... -
在github上建立自己的开源项目
2011-03-26 00:12 1987由于代码一直在自己这保存，一方面别人看不见，也不安全。搜了下， ... -
从ant到maven -- maven pom例子（初级）转
2011-02-27 00:46 1512http://hi.baidu.com/javajiwei/b ... -
从一个男人身上看出他的修养和抱负
2011-02-15 23:07 858一、拥有自信和风度 男人到了二十几岁后，就要开始学着用心去经营 ... -
用CVS来管理自己的程序
2011-01-15 18:18 905每个编写程序的人也许 ... -
手机操作系统三国时代的结束
2011-01-11 00:19 957第一篇：Symbian正式崩盘，手机操作系统三国时代结束 ... -
如何使用搜索技巧来成为一名高效的程序员
2011-01-11 00:05 838没有人是完全独立的孤 ...
相关推荐
总结起来，"C#Java生成protobuf工具pro"是一个针对C#和Java开发者的专业protobuf工具，它能解析.proto文件并生成对应语言的代码，简化protobuf在多语言环境下的使用，提高开发效率，并可能提供了额外的数据转换和...
总之，实现Unity3D与Java之间的Protobuf通信涉及客户端的C#编程、Protobuf的序列化和反序列化、Socket编程，以及服务器端的Java处理。通过这种方式，可以实现高效、可靠的跨平台数据交换，适用于大型在线游戏和其他...
protobuf，全称Protocol ...C#和Java的开发者都可以利用protobuf的便利，通过.proto文件生成相应的代码，实现高效的数据处理和传输。ProtoBufTransForm工具则进一步帮助开发者在C#和Java之间进行protobuf消息的转换。
总的来说，"C#Java生成protobuf工具"是一个利用QT框架构建的实用软件，旨在简化C#和Java开发者使用protobuf的过程，帮助他们快速生成符合protobuf规范的代码，从而更高效地处理数据序列化和通信问题。通过这个工具，...
在Android中，使用`java.net.Socket`和`java.net.ServerSocket`进行socket通信。创建一个服务端线程监听特定端口，等待客户端连接，并接收protobuf消息。客户端则创建Socket连接到服务器，并发送protobuf序列化的...
总的来说，protobuf3转Java工具是开发者在使用protobuf3时不可或缺的辅助工具，它极大地简化了protobuf协议到Java代码的转换过程，提高了开发效率，同时利用protobuf的优势实现了高效的数据交换。对于处理大规模数据...
**protobuf与Java和C#** 在Java和C#中使用protobuf，开发者首先需要编写.proto文件，这是一种定义数据结构的文本文件。.proto文件包含消息类型定义，类似于编程语言中的类。例如： ```protobuf syntax = "proto3";...
- 在Unity中，你可以使用System.Net命名空间下的Socket类进行网络编程，包括创建ServerSocket和ClientSocket。 4. **Unity3D结合Protobuf实现Socket通信**： - **服务器端**：创建ServerSocket监听特定端口，当...
protobuf c#转换工具-支持proto2 简介：Protocol Buffers 是一种轻便高效的结构化数据存储格式，可以用于结构化数据串行化，或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域...
Google Protobuf 在 Linux Socket 通讯中的应用 Google Protobuf 是一种高效、可扩展的数据格式，提供了对结构化数据的编码方案。它可以将结构化数据持久化或序列化成网络传输的数据。 Protobuf 在 Linux 平台下的...
3. **压缩策略**：对于网络传输场景，可以利用Protobuf自带的压缩功能或者第三方库如LZ4等来进行数据压缩，减少带宽消耗。 #### 五、注意事项 1. **版本兼容性**：确保使用的protoc编译器版本与Unity项目中的.NET ...
1.Scripts/Socket/Protobuf：Protobuf源码 2.Scripts/Socket/ProtocalData: 存放*.proto 转换后的 *.cs 协议数据结构文件 3.Scripts/Socket： 其他，Socket相关脚本。 备注：使用的是Protobuf的源码，如果后期有效...
本Demo展示了如何在Unity中利用ProtoBuf与Java环境下的Netty服务器进行通信。 ProtoBuf是由Google开发的一种数据序列化协议，它能将结构化数据转化为二进制流，以减少网络传输的数据量，提高通信效率。Java和Unity...
在本文中，我们将深入探讨如何使用Java与Protocol Buffers（protobuf）3.5版本进行开发。Protocol Buffers是Google推出的一种高效的数据序列化协议，它允许开发者定义数据结构，然后生成能够在各种数据平台之间轻松...
标题中的“实现protobuf与json的互转”是指在软件开发中，如何将使用Protocol Buffers（protobuf）编写的结构体数据转换成JSON格式，反之亦然。Protocol Buffers是Google推出的一种数据序列化协议，而JSON...
本文将详细讲解如何配置一个使用Google Protocol Buffers（protobuf）进行C++和C#之间无障碍通信的环境，并提供相关的配置和脚本步骤。 首先，你需要下载并安装protobuf的源代码和编译工具。在protobuf的官方网站上...
在本实例中，“protobuf实例-C#-聊天服务器”是基于C#语言实现的一个聊天服务项目，利用protobuf进行数据序列化和反序列化，以便于在网络通信中高效地传输聊天消息。 在C#环境下，protobuf提供了编译器工具，可以将...
在本项目中，“Android应用源码安卓与PC的Socket通信项目C#版”是一个实现Android设备与个人计算机（PC）之间通过Socket进行通信的应用。这个项目涵盖了Android编程、网络编程和C#编程等多个IT领域的知识，以下是...
总之，protobuf在Socket中的运用提供了高效、可扩展的数据传输方式，使得客户端能够通过Socket与服务器进行结构化数据的交互。结合具体的“TestProtocolBufers电话薄例子”，我们可以深入学习如何在实践中结合...