百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分析 > 正文

如何在skynet框架中使用socket+protobuf

liebian365 2024-10-24 14:39 23 浏览 0 评论

引言:

假如我们要建立的skynet服务器与客户端的连接方式为长连接,且选择了Google的Protobuf来定制我们的网络协议,那么,接下来我们要解决的问题就是:如何在skynet框架中使用socket+protobuf

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源码一样,通过gitpbc的源码克隆到本地:

bogon:project linshuhe$ git clone https://github.com/cloudwu/pbc.git
Cloning into 'pbc'...
remote: Counting objects: 1156, done.
remote: Total 1156 (delta 0), reused 0 (delta 0), pack-reused 1156
Receiving objects: 100% (1156/1156), 302.95 KiB | 310.00 KiB/s, done.
Resolving deltas: 100% (682/682), done.
Checking connectivity... done.

编译并合入项目:

项目编译:
可以在pbc根目录下运行make指令编译项目:

linsh@ubuntu:/application/pbc$ sudo make
cd 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.o
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o addressbook ../test/addressbook.c -lpbc
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o pattern ../test/pattern.c -lpbc
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o pbc ../test/pbc.c -lpbc
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o float ../test/float.c -lpbc
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o map ../test/map.c -lpbc
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o test ../test/test.c -lpbc
cd build && gcc -O2 -fPIC -Wall -I.. -L. -o decode ../test/decode.c -lpbc
protoc -obuild/addressbook.pb test/addressbook.proto
protoc -obuild/descriptor.pb test/descriptor.proto
protoc -obuild/float.pb test/float.proto
protoc -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

给大家推荐一个关于skynet项目实战的一个训练营 现在报名相当于免费,(后台私信“skynet”获取地址)主讲内容:

多核并发编程
消息队列。线程池
actor消息调度
网络模块实现
时间轮定时器实现
lua/c/接口编程
skynet编程精要
demo演示actor编程思维

更多skynet及c/c++ linux服务器开发资料加群:
812855908免费领取!

包括C/C++,Linux,golang技术,Nginx,ZeroMQ,MySQL,Redis,fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK,ffmpeg等

工具编译:
用终端进入pbc项目
pbc/binding/lua53目录下面编译出protobuf.so:

cd pbc/binding/lua
sudo make

编译成功的话,将protobuf.so放在config文件中lua_cpath项配置的目录下面,同时将protobuf.lua放在config文件lua_path配置的目录下,就可以调用protobuf中的库方法。我当前项目这两项的配置如下:

lua_path = root.."lualib/?.lua;"..root.."lualib/?/init.lua"
lua_cpath = root .. "luaclib/?.so"

则移动文件命令可以如下:

sudo cp protobuf.so /application/skynet/luaclib 
sudo cp protobuf.lua /application/skynet/lualib

编译报错:

pbc/binding/lua目录下编译,出现以下错误:

linsh@ubuntu:/application/pbc/binding/lua$ sudo make
gcc -O2 -fPIC -Wall -shared -o protobuf.so -I../.. -I/usr/local/include -L../../build pbc-lua.c -lpbc
pbc-lua.c:4:17: fatal error: lua.h: 没有那个文件或目录
#include "lua.h"
                ^
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.gz
File 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
程序 'lua' 已包含在下列软件包中:
* 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$ lua
Lua 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 make
gcc -O2 -fPIC -Wall -shared -o protobuf.so -I../.. -I/usr/local/src/lua-5.3.0/src -L../../build pbc-lua.c -lpbc
linsh@ubuntu:/application/pbc/binding/lua$ ls
build_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 "protobuf" 1

注册.proto协议文件所对应的.pb文件,注册方法有两种:

方法一:直接注册文件:

pb.register_file "Person.pb" 

方法二:通过io读取文件,然后再获取文本内容进行注册:

file = io.open("Person.pb","rb") 
buffer = file:read "*a" 
file:close() 
pb.register(buffer) 

通过 encode 和 decode 两个接口来实现编码和解码,完整测试脚本:

 local skynet = require "skynet" 
local protobuf = require "protobuf" 
skynet.start(function() 
protobuf.register_file "./protos/Person.pb" 
skynet.error("注册协议文件:Person.pb") 
stringbuffer = protobuf.encode("cs.Person", { 
name = "linsh", 
id = 1,
 }) 
local data = protobuf.decode("cs.Person",stringbuffer) 
skynet.error("数据编码:name="..data.name..",id="..data.id) 
end) 
``` 

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

运行正确的结果:

[:0100000c] 注册协议文件:Person.pb
[:0100000c] 数据编码:name=linsh,id=1

除外,云风还自定义了一套协议格式sproto,据说比protobuf还要简单。

相关推荐

快递查询教程,批量查询物流,一键管理快递

作为商家,每天需要查询许许多多的快递单号,面对不同的快递公司,有没有简单一点的物流查询方法呢?小编的回答当然是有的,下面随小编一起来试试这个新技巧。需要哪些工具?安装一个快递批量查询高手快递单号怎么快...

一键自动查询所有快递的物流信息 支持圆通、韵达等多家快递

对于各位商家来说拥有一个好的快递软件,能够有效的提高自己的工作效率,在管理快递单号的时候都需要对单号进行表格整理,那怎么样能够快速的查询所有单号信息,并自动生成表格呢?1、其实方法很简单,我们不需要一...

快递查询单号查询,怎么查物流到哪了

输入单号怎么查快递到哪里去了呢?今天小编给大家分享一个新的技巧,它支持多家快递,一次能查询多个单号物流,还可对查询到的物流进行分析、筛选以及导出,下面一起来试试。需要哪些工具?安装一个快递批量查询高手...

3分钟查询物流,教你一键批量查询全部物流信息

很多朋友在问,如何在短时间内把单号的物流信息查询出来,查询完成后筛选已签收件、筛选未签收件,今天小编就分享一款物流查询神器,感兴趣的朋友接着往下看。第一步,运行【快递批量查询高手】在主界面中点击【添...

快递单号查询,一次性查询全部物流信息

现在各种快递的查询方式,各有各的好,各有各的劣,总的来说,还是有比较方便的。今天小编就给大家分享一个新的技巧,支持多家快递,一次能查询多个单号的物流,还能对查询到的物流进行分析、筛选以及导出,下面一起...

快递查询工具,批量查询多个快递快递单号的物流状态、签收时间

最近有朋友在问,怎么快速查询单号的物流信息呢?除了官网,还有没有更简单的方法呢?小编的回答当然是有的,下面一起来看看。需要哪些工具?安装一个快递批量查询高手多个京东的快递单号怎么快速查询?进入快递批量...

快递查询软件,自动识别查询快递单号查询方法

当你拥有多个快递单号的时候,该如何快速查询物流信息?比如单号没有快递公司时,又该如何自动识别再去查询呢?不知道如何操作的宝贝们,下面随小编一起来试试。需要哪些工具?安装一个快递批量查询高手快递单号若干...

教你怎样查询快递查询单号并保存物流信息

商家发货,快递揽收后,一般会直接手动复制到官网上一个个查询物流,那么久而久之,就会觉得查询变得特别繁琐,今天小编给大家分享一个新的技巧,下面一起来试试。教程之前,我们来预览一下用快递批量查询高手...

简单几步骤查询所有快递物流信息

在高峰期订单量大的时候,可能需要一双手当十双手去查询快递物流,但是由于逐一去查询,效率极低,追踪困难。那么今天小编给大家分享一个新的技巧,一次能查询多个快递单号的物流,下面一起来学习一下,希望能给大家...

物流单号查询,如何查询快递信息,按最后更新时间搜索需要的单号

最近有很多朋友在问,如何通过快递单号查询物流信息,并按最后更新时间搜索出需要的单号呢?下面随小编一起来试试吧。需要哪些工具?安装一个快递批量查询高手快递单号若干怎么快速查询?运行【快递批量查询高手】...

连续保存新单号功能解析,导入单号查询并自动识别批量查快递信息

快递查询已经成为我们日常生活中不可或缺的一部分。然而,面对海量的快递单号,如何高效、准确地查询每一个快递的物流信息,成为了许多人头疼的问题。幸运的是,随着科技的进步,一款名为“快递批量查询高手”的软件...

快递查询教程,快递单号查询,筛选更新量为1的单号

最近有很多朋友在问,怎么快速查询快递单号的物流,并筛选出更新量为1的单号呢?今天小编给大家分享一个新方法,一起来试试吧。需要哪些工具?安装一个快递批量查询高手多个快递单号怎么快速查询?运行【快递批量查...

掌握批量查询快递动态的技巧,一键查找无信息记录的两种方法解析

在快节奏的商业环境中,高效的物流查询是确保业务顺畅运行的关键。作为快递查询达人,我深知时间的宝贵,因此,今天我将向大家介绍一款强大的工具——快递批量查询高手软件。这款软件能够帮助你批量查询快递动态,一...

从复杂到简单的单号查询,一键清除单号中的符号并批量查快递信息

在繁忙的商务与日常生活中,快递查询已成为不可或缺的一环。然而,面对海量的单号,逐一查询不仅耗时费力,还容易出错。现在,有了快递批量查询高手软件,一切变得简单明了。只需一键,即可搞定单号查询,一键处理单...

物流单号查询,在哪里查询快递

如果在快递单号多的情况,你还在一个个复制粘贴到官网上手动查询,是一件非常麻烦的事情。于是乎今天小编给大家分享一个新的技巧,下面一起来试试。需要哪些工具?安装一个快递批量查询高手快递单号怎么快速查询?...

取消回复欢迎 发表评论: