`
hideto
  • 浏览: 2679509 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

C++和Ruby使用protobuf做Socket通信

    博客分类:
  • C++
阅读更多
1, people.proto
package demo;

message People {
  required string name = 1;
  required int32 id = 2;
  required string email = 3;
}


2, 生成stub类
protoc --cpp_out=. people.proto
rprotoc people.proto


3, C++服务器端server.cc
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string>
#include <iostream>
#include "people.pb.h"

#define PORT 8888
#define MAXDATASIZE 20
#define BACKLOG 10

using namespace std;

int main()
{
  int listenfd, connectfd, numbytes;
  char buf[MAXDATASIZE];
  struct sockaddr_in server;
  struct sockaddr_in client;
  int sin_size;

  listenfd = socket(AF_INET, SOCK_STREAM, 0);

  int opt = SO_REUSEADDR;
  setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

  bzero(&server, sizeof(server));
  server.sin_family = AF_INET;
  server.sin_port = htons(PORT);
  server.sin_addr.s_addr = htonl(INADDR_ANY);

  bind(listenfd, (struct sockaddr *)&server, sizeof(struct sockaddr));

  listen(listenfd,BACKLOG);

  while(1){
    sin_size = sizeof(struct sockaddr_in);

    connectfd = accept(listenfd, (struct sockaddr *)&client, &sin_size);

    numbytes = recv(connectfd, buf, MAXDATASIZE, 0);
    buf[numbytes] = '\0';
    string a = buf;
    cout << "You got a message from " << inet_ntoa(client.sin_addr) << endl;
    cout << "Client Message: " << a << endl;
    if(a == "GET PEOPLE") {
      string data;
      demo::People p;
      p.set_name("Hideto");
      p.set_id(123);
      p.set_email("hideto.bj@gmail.com");
      p.SerializeToString(&data);
      char bts[data.length()];
      strcpy(bts, data.c_str());
      send(connectfd, bts, sizeof(bts), 0);
    } else {
      send(connectfd, "Fucking client!\n", 16, 0);
    }
    close(connectfd);
  }

  close(listenfd);
  return 0;
}


4, C++客户端client.cc
#include <stdio.h>
#include <unistd.h>
#include <strings.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <string>
#include <iostream>
#include "people.pb.h"

#define HOST "localhost"
#define PORT 8888
#define MAXDATASIZE 100

using namespace std;

int main(int argc, char ** argv)
{
  int fd, numbytes;
  char buf[MAXDATASIZE];
  struct hostent *he;
  struct sockaddr_in server;
  
  if (argc != 2) {
    printf("Usage: %s \"COMMAND\"\n",argv[0]);
    exit(0);
  } 
  
  he = gethostbyname(HOST);
  fd = socket(AF_INET, SOCK_STREAM, 0);
  bzero(&server, sizeof(server));
  server.sin_family = AF_INET;
  server.sin_port = htons(PORT);
  server.sin_addr = *((struct in_addr *)he->h_addr);

  connect(fd, (struct sockaddr *)&server, sizeof(struct sockaddr));

  send(fd, argv[1], 20, 0);

  numbytes = recv(fd, buf, MAXDATASIZE, 0);
  buf[numbytes] = '\0';
  string data = buf;
  demo::People p;
  p.ParseFromString(data);
  cout << "People: " << endl;
  cout << "Name: " << p.name() << endl;
  cout << "ID: " << p.id() << endl;
  cout << "Email: " << p.email() << endl;

  close(fd);
  return 0;
}


5, Ruby客户端client.rb
require 'socket'
require 'people.pb.rb'

HOST = "localhost"
PORT = 8888

client = TCPSocket.open(HOST, PORT)
client.send("GET PEOPLE", 0)
client.close_write
s = client.read
p = Demo::People.new
p.parse_from_string s
p p


6, 使用g++编译
$ g++ server.cc people.pb.cc -o s -lprotobuf
$ g++ client.cc people.pb.cc -o c -lprotobuf


7, 运行
#启动server
./s

You got a message from 127.0.0.1
Client Message: GET PEOPLE
You got a message from 127.0.0.1
Client Message: GET PEOPLE

#运行c++的client
./c "GET PEOPLE"

People:
Name: Hideto
ID: 123
Email: hideto.bj@gmail.com


#运行Ruby的client
ruby client.rb

name: "Hideto"
id: 123
email: "hideto.bj@gmail.com"
分享到:
评论

相关推荐

    Android中基于protobuf的socket通信的实例

    本实例将深入探讨如何在Android应用中使用protobuf进行基于socket的通信。 首先,理解protobuf的基本原理是至关重要的。protobuf通过定义.proto文件来描述数据结构,然后使用protoc编译器生成对应语言的类文件。在...

    基于C++实现使用protobuf完成网络通信源码.zip

    基于C++实现使用protobuf完成网络通信源码.zip基于C++实现使用protobuf完成网络通信源码.zip基于C++实现使用protobuf完成网络通信源码.zip基于C++实现使用protobuf完成网络通信源码.zip基于C++实现使用protobuf完成...

    C++使用protobuf 作为网络消息协议

    标题中的"C++使用protobuf作为网络消息协议"指出,我们将探讨如何在C++编程环境中利用Protocol Buffers(protobuf)这一高效的数据序列化工具来构建网络通信的消息协议。protobuf是由Google开发的一种语言中立、平台...

    protobuf 在socket中运用 客户端

    标题中的“protobuf在socket中运用客户端”指的是使用Google的Protocol Buffers(protobuf)协议来编码数据,并通过Socket通信协议在客户端进行数据传输的一种技术实践。Protocol Buffers是一种高效、跨平台的数据...

    unity3d&Protobuf&Socket

    这时,开发者通常会选择自定义网络通信方案,例如使用Socket和Protobuf。 1. **Protobuf简介**: - Protobuf是一种轻量级的数据序列化协议,它可以将复杂的数据结构转换为二进制流,以便在网络间高效地传输。相比...

    Unity+protobuf+Socket通信

    整合Unity+Protobuf+Socket的一个游戏案例,里面包括服务器和客户端各一个socket,通过线程管理来保证多个连接请求同步。案例简单,但在实际开发中很常用。通过稍微修改,就可以用在实际项目里。编程语言是C#,都加了...

    protobuf 在socket中的例子

    以下将详细介绍protobuf在Socket通信中的应用,以及如何在指定的目录“ym_vcpp-txsl\ym_vcpp-txsl\PublicNetSoft”下使用protobuf源码库。 首先,理解protobuf的基本概念。protobuf是一种语言无关、平台无关的接口...

    UE4使用protobuf与服务器通信

    ### UE4使用protobuf与服务器通信 #### 获取protobuf源代码及工具安装 为了在UE4(Unreal Engine 4)中使用protobuf进行网络通信,首先需要获取protobuf的源代码。这通常涉及以下步骤: 1. **安装Git for Windows...

    protobuf_socket.zip

    ProtoBuf是一种序列化数据的框架,常用于网络通信和数据交换,而Socket则是实现网络通信的基础接口。从标签"socket"我们可以推测,这个压缩包可能包含了使用ProtoBuf进行Socket通信的相关示例或库。 在网络编程中,...

    protobuf-3.8.0 VS2019 C++使用案例

    在C++中使用protobuf,主要是为了实现跨平台的数据交换,提高数据存储和网络传输的效率。在VS2019环境下,我们可以创建一个C++项目来体验protobuf的使用。 首先,你需要下载并安装protobuf-3.8.0版本的库。这个版本...

    protobuf开发socket

    标题中的“protobuf开发socket”指的是使用Google的Protocol Buffers(Protobuf)协议来开发网络通信中的Socket应用程序。Protobuf是一种高效的数据序列化框架,它能够将结构化的数据转化为二进制格式,从而节省网络...

    Unity3D Socket通信使用Protobuf数据格式

    测试脚本: Client.cs 测试内容: 1.连接服务器。 2.断开服务器。 3.发送游戏事件。...(注意:.Net 2.0 的库和 .Net 2.0 Subset的选择使用。代码中只需要维护 SocketManager.cs 中的两个静态序列化相关函数即可)

    google protobuf 生成c++ c#无障碍通信环境配置及脚本

    本文将详细讲解如何配置一个使用Google Protocol Buffers(protobuf)进行C++和C#之间无障碍通信的环境,并提供相关的配置和脚本步骤。 首先,你需要下载并安装protobuf的源代码和编译工具。在protobuf的官方网站上...

    protobuf中的命名空间使用demo(C++)

    1. **头文件包含**:生成的C++代码会将消息类型放入对应的命名空间,所以在包含protobuf生成的头文件时,需要使用`和`&gt;`来包裹,例如`#include &lt;mycompany/myapp/person.pb.h&gt;`。 2. **使用命名空间**:在C++代码中...

    linux_QT_GOOGLEPROTOBUF_SOCKET

    这个"linux_QT_GOOGLEPROTOBUF_SOCKET"项目显然结合了这些技术,旨在创建一个示例应用,展示如何在Linux环境下使用QT图形界面库与Google Protobuf进行数据序列化,并通过Socket通信。以下是关于这些知识点的详细解释...

    C++_protobuf

    总的来说,C++_protobuf是C++中使用protobuf这一高效序列化工具的实践,它可以极大地简化网络通信中数据表示和交换的复杂性,提升系统性能,同时保证了跨平台和版本兼容性。在实际项目中,合理运用protobuf能显著...

    C++ protobuf debug release动态库和静态库

    标题 "C++ protobuf debug release动态库和静态库" 涉及的是Google的Protocol Buffers(简称protobuf)在C++中的应用,特别是如何构建和使用protobuf的动态库和静态库。Protocol Buffers是一种数据序列化协议,允许...

    zeromq和protobuf的c++示例代码适合初学者快速了解,上手

    通过学习这个示例,你可以掌握如何在C++中创建zeromQ客户端和服务端,以及如何使用protobuf定义消息类型和进行数据序列化。这将对你的后端开发技能有很大提升,因为这两个工具在现代分布式系统中被广泛使用。

Global site tag (gtag.js) - Google Analytics