c++使用protobuf与GO语言做数据通信

protobuf C++
0 69
suoniao 2020-10-20
需要:0索币

安装proto的go语言插件

go get code.google.com/p/goprotobuf/{proto,protoc-gen-go}


编写一个简单的事例,go与c++网络通信:

RegMessage.proto

package cn.vicky.model.seri;

message RegMessage {
    required int32 id = 1; // 主键,唯一
    required string username = 2; // 帐号
    required string password = 3; // 密码
    optional string email = 4; // 邮箱(可选)
}


执行:
protoc --cpp_out=. RegMessage.proto

protoc --go_out=. RegMessage.proto


生成对应的c++源文件和go源文件

RegMessage.pb.h

RegMessage.pb.cc

RegMessage.pb.go


go语言做客户端代码:

// Code generated by protoc-gen-go.
// source: RegMessage.proto
// DO NOT EDIT!

package main

import "fmt"
import "os"
import "net"
import proto "code.google.com/p/goprotobuf/proto"
import json "encoding/json"
import math "math"

// Reference proto, json, and math imports to suppress error if they are not otherwise used.
var _ = proto.Marshal
var _ = &json.SyntaxError{}
var _ = math.Inf

type RegMessage struct {
	Id               *int32  `protobuf:"varint,10001,req,name=id" json:"id,omitempty"`
	Username         *string `protobuf:"bytes,2,req,name=username" json:"username,omitempty"`
	Password         *string `protobuf:"bytes,3,req,name=password" json:"password,omitempty"`
	Email            *string `protobuf:"bytes,4,opt,name=email" json:"email,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (m *RegMessage) Reset()         { *m = RegMessage{} }
func (m *RegMessage) String() string { return proto.CompactTextString(m) }
func (*RegMessage) ProtoMessage()    {}

func (m *RegMessage) GetId() int32 {
	if m != nil && m.Id != nil {
		return *m.Id
	}
	return 0
}

func (m *RegMessage) GetUsername() string {
	if m != nil && m.Username != nil {
		return *m.Username
	}
	return ""
}

func (m *RegMessage) GetPassword() string {
	if m != nil && m.Password != nil {
		return *m.Password
	}
	return ""
}

func (m *RegMessage) GetEmail() string {
	if m != nil && m.Email != nil {
		return *m.Email
	}
	return ""
}

func init() {
}

func main() {
	regMessage := &RegMessage{
		Id:       proto.Int32(10001),
		Username: proto.String("vicky"),
		Password: proto.String("123456"),
		Email:    proto.String("eclipser@163.com"),
	}
	buffer, err := proto.Marshal(regMessage)
	if err != nil {
		fmt.Printf("failed: %s\n", err)
		return
	}

	pTCPAddr, err := net.ResolveTCPAddr("tcp", "192.168.1.98:7070")
	if err != nil {
		fmt.Fprintf(os.Stderr, "Error: %s", err.Error())
		return
	}
	pTCPConn, err := net.DialTCP("tcp", nil, pTCPAddr)
	if err != nil {
		fmt.Fprintf(os.Stderr, "Error: %s", err.Error())
		return
	}
	pTCPConn.Write(buffer)
}


正常情况下是不建议修改protoc生成的源文件的,我们这里图省事,直接在生成的RegMessage.pb.go添加网络发送代码。

使用C++编写简单的socket服务器:


/* 
 * File:   main.cpp
 * Author: Vicky.H
 * Email:  eclipser@163.com
 */
#include <cstdio>
#include <cstdlib>
#include <iostream>

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>

#include "RegMessage.pb.h"

void* connHandler(void *pConn) {
    int* _pConn = static_cast<int*> (pConn);
    for (;;) {
        void* buf = malloc(1024);
        int n = read(*_pConn, buf, 1024);
        
        cn::vicky::model::seri::RegMessage regMessage;
        regMessage.ParseFromArray(buf, n);
        
        std::cout << regMessage.id() << std::endl;
        std::cout << regMessage.username() << std::endl;
        std::cout << regMessage.password() << std::endl;
        std::cout << regMessage.email() << std::endl;
        
        close(*_pConn);
        free(buf);
    }
    return pConn;
}

/*
 * 
 */
int main(void) {

    int sock = socket(AF_INET, SOCK_STREAM, 0);
    if (sock == -1) {
        perror("创建Socket失败!");
        return EXIT_FAILURE;
    }

    struct sockaddr_in addr;
    addr.sin_port = htons(7070);
    inet_pton(AF_INET, "192.168.1.98", &addr.sin_addr);

    int result;
    result = bind(sock, (struct sockaddr*) &addr, sizeof (struct sockaddr_in));
    if (result != 0) {
        perror("绑定地址失败!");
        return EXIT_FAILURE;
    }

    result = listen(sock, 10);
    if (result != 0) {
        perror("监听失败!");
        return EXIT_FAILURE;
    }

    for (;;) {
        int conn = accept(sock, NULL, NULL);
        if (conn == -1) {
            perror("与客户端建立连接失败!");
            continue;
        }
        pthread_t thread;
        pthread_create(&thread, NULL, connHandler, (void*) &conn);
    }

    return 0;
}



需要连接 -lpthread -lprotobuf 



分别运行c++程序,go run RegMessage.pb.go

打印:

1
vicky
123456

eclipser@163.com

来源:https://studygolang.com/articles/899

回帖
  • 消灭零回复
广告一下
程序员转型,副业赚钱教程
相关主题
最新C++入门到实战教程 c++实现计算器和QQ登录框 0
c++使用protobuf与GO语言做数据通信 0
QTreeView 节点行的动态添加和删除removeRow 0
QT的QTreeView设置表头自适应宽度显示的方法 0
C++获取当前正在使用的网卡的IP地址信息 0
C++网络编程实践实现RPC框架SOCKS4a服务器实现Roundtrip代码分析网络时间同步 0
C++教程网跟我一起学C++总共三季 0
QT5获取剪贴板上文本信息QT设置剪贴板内容 1
智联互锋一期C语言及C++工程师培训全 数据结构 0
xiaomage编程基础必备之30小时快速精通C++逆向编程 0
C语言与C++数据库编程开发视频 0
2016版C++ QT界面开发视频 0
C++基于QT开发中国象棋游戏视频完整PC游戏编程人机博弈 0
炼数C++基础入门十四周培训视频教程 0
用C++和boost库开发一个NoSQL数据库实战教程 0
大数据方向的C语言和C++编程语言培训 0
C++ Primer高级进阶教程 0
C++ Primer初级入门教程 0
C++ Primer中级教程 0
传智播客C语言提高特训专题 0
相关主题
Qt实战分布式网盘系统实战Qt文件上传下载 0
Qt5实战教程之翻金币游戏开发 0
利用C++库QT实现秘钥分发系统 秘钥协商 校验 查看服务 0
最新C++入门到实战教程 c++实现计算器和QQ登录框 0
Qt开发物联网智能网关项目教程 0
Qt开发打地鼠游戏实战 QT学生管理系统实战教程 0
大龄程序员转型、程序员副业赚钱实战教程合集 0
程序员副业赚钱之抖音短视频制作实战教程 0
程序员副业赚钱之程序员投资赚钱实战教程 0
程序员副业赚钱之利用抖音短视频获取收入实战 0
程序员副业赚钱之抖音电商实战教程 0
程序员副业赚钱之利用豆瓣引流赚钱实战 0
程序员副业赚钱之抓住自媒体风口月入过万不是问题今日头条实战 0
程序员副业赚钱之靠搬运视频赚钱实战 0
程序员副业赚钱之靠写作技术文章实现收益 写作教程 0
程序员副业赚钱之利用知乎引流实现月入过万实战 0
程序员副业赚钱之利用个人IP打造月入5万项目 0
程序员副业赚钱之利用社群营销 打造躺赚个人号 0
程序员副业赚钱之靠运行公众号月入10万多哦 0
程序员副业赚钱之打造一个赚钱的快手号 0