skynet框架如何使用socket+protobuf

fwalker · 发表于 2022-9-5 14:12

引言：

假如我们要建立的skynet服务器与客户端的连接方式为长连接，且选择了Google的Protobuf来定制我们的网络协议，那么，接下来我们要解决的问题就是：如何在skynet框架中使用socket+protobuf。
视频教程推荐：
【全网独家】高薪岗位DPDK高性能虚拟专家学习路线
【备战秋招】C/C++程序员可以安心躺平的音视频流媒体开发
【鹅厂T8认证】2022年LinuxC/C++后台开发最强学习路线图
【备战秋招】互联网大厂秋招，嵌入式从入门到精通（小白零基础速学）
API

几个常用的skynet接口：
* 输出错误信息： skynet.error(...)* 获取本地服务句柄方式： skynet.localname(...)* 设置定时器方式： skynet.timeout(...)* skynet强制退出方式： skyname.abort()* 服务开始方式： skynet.start(...)* 服务注销方式： skynet.exit()* 发送原始文本消息方式： skynet.core.send(...)protobuf在skynet中使用：

由于protobuf的lua版本的支持存在着部分缺陷，为了避免踩坑，这里我们直接使用云风博客中推荐的pbc动态proto解析库。
资源下载：

下载pbc：跟下载skynet源码一样，通过git将pbc的源码克隆到本地：
bogon:project linshuhe$ git clone https://github.com/cloudwu/pbc.gitCloning into &#39;pbc&#39;...remote: Counting objects: 1156, done.remote: Total 1156 (delta 0), reused 0 (delta 0), pack-reused 1156Receiving objects: 100% (1156/1156), 302.95 KiB | 310.00 KiB/s, done.Resolving deltas: 100% (682/682), done.Checking connectivity... done.

【文章福利】小编推荐自己的Linux C++技术交流群:【1106675687】整理了一些个人觉得比较好的学习书籍、视频资料共享在群文件里面，有需要的可以自行添加哦！！！前100名进群领取，额外赠送大厂面试题。

资料领取直通车：大厂面试题锦集+视频教程
免费学习网站：C/C++Linux服务器开发/后台架构师
编译并合入项目：

项目编译：
可以在pbc根目录下运行make指令编译项目：
linsh@ubuntu:/application/pbc$ sudo makecd build && ar rc libpbc.a ../build/o/context.o ../build/o/varint.o ../build/o/array.o ../build/o/pattern.o ../build/o/register.o ../build/o/proto.o ../build/o/map.o ../build/o/alloc.o ../build/o/rmessage.o ../build/o/wmessage.o ../build/o/bootstrap.o ../build/o/stringpool.o ../build/o/decode.ocd build && gcc -O2 -fPIC -Wall -I.. -L. -o addressbook ../test/addressbook.c -lpbccd build && gcc -O2 -fPIC -Wall -I.. -L. -o pattern ../test/pattern.c -lpbccd build && gcc -O2 -fPIC -Wall -I.. -L. -o pbc ../test/pbc.c -lpbccd build && gcc -O2 -fPIC -Wall -I.. -L. -o float ../test/float.c -lpbccd build && gcc -O2 -fPIC -Wall -I.. -L. -o map ../test/map.c -lpbccd build && gcc -O2 -fPIC -Wall -I.. -L. -o test ../test/test.c -lpbccd build && gcc -O2 -fPIC -Wall -I.. -L. -o decode ../test/decode.c -lpbcprotoc -obuild/addressbook.pb test/addressbook.protoprotoc -obuild/descriptor.pb test/descriptor.protoprotoc -obuild/float.pb test/float.protoprotoc -obuild/test.pb test/test.proto假如编译结果报错了：
make: protoc：命令未找到make: *** [build/addressbook.pb] 错误 127这是因为当前环境还没安装 protobuf，安装步骤如下：
指令安装：
sudo apt-get install protobuf-c-compiler protobuf-compiler 1查询版本验证完成：
linsh@ubuntu:/application/pbc$ protoc --version libprotoc 2.5.0 12
工具编译：
用终端进入pbc项目pbc/binding/lua53目录下面编译出protobuf.so：
cd pbc/binding/luasudo make编译成功的话，将protobuf.so放在config文件中lua_cpath项配置的目录下面，同时将protobuf.lua放在config文件lua_path配置的目录下，就可以调用protobuf中的库方法。我当前项目这两项的配置如下：
lua_path = root..&#34;lualib/?.lua;&#34;..root..&#34;lualib/?/init.lua&#34;lua_cpath = root .. &#34;luaclib/?.so&#34;则移动文件命令可以如下：
sudo cp protobuf.so /application/skynet/luaclib sudo cp protobuf.lua /application/skynet/lualib编译报错：

在pbc/binding/lua目录下编译，出现以下错误：
linsh@ubuntu:/application/pbc/binding/lua$ sudo makegcc -O2 -fPIC -Wall -shared -o protobuf.so -I../.. -I/usr/local/include -L../../build pbc-lua.c -lpbcpbc-lua.c:4:17: fatal error: lua.h: 没有那个文件或目录#include &#34;lua.h&#34;             ^compilation terminated.make: *** [protobuf.so] 错误 1报错原因：这里因为没有安装 lua5.3，不能是lua5.2或是lua5.1等低版本，否则会报错。因为pbc用到了lua_rotate这是lua5.3新增的类型。
解决方案： 安装一下 lua5.3 即可解决，步骤如下：
到lua官网下载lua5.3的安装包：
lua-5.3.0.tar.gz
也可以使用命令行下载工具 axel：
linsh@ubuntu:/application/pbc/binding$ sudo axel http://www.lua.org/ftp/lua-5.3.0.tar.gz初始化下载: http://www.lua.org/ftp/lua-5.3.0.tar.gzFile size: 278045 bytes打开输出文件 lua-5.3.0.tar.gz开始下载[  0%]  .......... .......... .......... .......... ..........  [  53.8KB/s][ 18%]  .......... .......... .......... .......... ..........  [  73.1KB/s][ 36%]  .......... .......... .......... .......... ....连接 3 结束       ,,,,,,,,,, ,,,,,,,,,, ,,,,,,,,,, ,,,,,,,,,, ,,,,......  [  96.9KB/s][ 55%]  .......... .......... .......... .......... ..........  [  92.5KB/s][ 73%]  .......... .......... .......... ......连接 0 结束       ,,,,,,,,,, ,,,,,,,,,, ,,,,,,,,,, ,,,,,,.... ........连接 1 结束       ,,,,,,,,,, ,,,,,,,,,, ,,,,,,,,,, ,,,,,,,,,, ,,,,,,,,..  [  80.5KB/s][ 92%]  .......... .......... .271.5 千字节已下载，用时 6 秒。（43.52 千字节/秒）使用压缩包进行解压和安装：
先将下载好的文件拷贝到usr/local/src目录下
sudo cp lua-5.3.0.tar.gz /usr/local/src依次执行以下指令：
sudo tar zxf lua-5.3.0.tar.gz cd lua-5.3.0/ sudo make linux test创建软链接，是lua可以在当前环境下随处可用：
sudo ln -s /usr/local/src/lua-5.3.0/src/lua /usr/bin/lua测试一下软连接是否成功：
linsh@ubuntu:/usr/local/src/lua-5.3.0/src$ lua程序 &#39;lua&#39; 已包含在下列软件包中：* lua5.2* lua5.1* lua50请尝试：sudo apt-get install <选定的软件包>我也出现过这个问题，最后查到原因是因为添加软链接时第一个地址（lua的安装地址）/usr/local/src/lua-5.3.0/src/lua被我写成了/usr/local/src/lua5.3.0/src/lua，解决问题和可以看到：
linsh@ubuntu:/usr/bin$ luaLua 5.3.0  Copyright (C) 1994-2015 Lua.org, PUC-Rio>修改pbc/binding/lua/Makefile中lua库的地址配置信息LUADIR为当前lua安装的地址：
LUADIR = /usr/local/src/lua-5.3.0/src 1再次运行编译指令，并查询当前目录下文件的变化：
linsh@ubuntu:/application/pbc/binding/lua$ sudo makegcc -O2 -fPIC -Wall -shared -o protobuf.so -I../.. -I/usr/local/src/lua-5.3.0/src -L../../build pbc-lua.c -lpbclinsh@ubuntu:/application/pbc/binding/lua$ lsbuild_ios.sh  Makefile  parser.lua  pbc-lua.c  protobuf.lua  protobuf.so  README.md  test2.lua  test.lua  testparser.lua测试：

先在项目根目录下创建一个protos文件夹，用来存放协议文件，创建一个Person.proto协议文件，内容如下：
sudo mkdir protos cd protos sudo vi Person.proto协议文件的内容如下：
package cs; message Person { required string name = 1; required int32 id = 2; // Unique ID number for this person. optional string email = 3; enum PhoneType { MOBILE = 0; HOME = 1; WORK = 2; } message PhoneNumber { required string number = 1; optional PhoneType type = 2 [default = HOME]; } repeated PhoneNumber phone = 4; }将协议文件到处为.pb格式：
linsh@ubuntu:/application/skynet/protos$ sudo protoc --descriptor_set_out Person.pb Person.proto linsh@ubuntu:/application/skynet/protos$ ls Person.pb Person.proto目录下多出了一个对应的.pb文件。
在lua中注册对应的协议文件：

引入protobuf.lua：
local pb = require &#34;protobuf&#34; 1注册.proto协议文件所对应的.pb文件，注册方法有两种：
方法一：直接注册文件：
pb.register_file &#34;Person.pb&#34; 方法二：通过io读取文件，然后再获取文本内容进行注册：
file = io.open(&#34;Person.pb&#34;,&#34;rb&#34;) buffer = file:read &#34;*a&#34; file:close() pb.register(buffer)通过 encode 和 decode 两个接口来实现编码和解码，完整测试脚本：
local skynet = require &#34;skynet&#34; local protobuf = require &#34;protobuf&#34; skynet.start(function() protobuf.register_file &#34;./protos/Person.pb&#34; skynet.error(&#34;注册协议文件：Person.pb&#34;) stringbuffer = protobuf.encode(&#34;cs.Person&#34;, { name = &#34;linsh&#34;, id = 1, }) local data = protobuf.decode(&#34;cs.Person&#34;,stringbuffer) skynet.error(&#34;数据编码：name=&#34;..data.name..&#34;,id=&#34;..data.id) end) ```

假如注册的协议文件依赖其他协议文件，则依赖的协议文件需要优先注册，否则会出现 register fail 的报错

运行正确的结果：
[:0100000c] 注册协议文件：Person.pb[:0100000c] 数据编码：name=linsh,id=1除外，云风还自定义了一套协议格式sproto，据说比protobuf还要简单。

<hr/>

		自动登录	找回密码
密码			立即注册

skynet框架如何使用socket+protobuf

本帖子中包含更多资源