【从零开始学Skynet】基础篇(四):网络模块常用API

news/2024/10/30 15:32:29/
        游戏服务端要处理客户端请求,作为服务端引擎,网络编程也是Skynet的核心功能。

1、学习网络模块

  skynet.socket模块提供了网络编程的API,常用的API如下表所示:
Lua API说明
socket.listen(address ,port)监听一个端口,返回一个 id ,供 start 使用。
socket.start(id , accept)  accept 是一个函数。每当一个监听的 id 对应的 socket 上有连接接入的时候,都会调用 accept 函数。这个函数会得到接入连接的 id 以及 ip 地址。你可以做后续操作。
socket.read(id, sz)从一个 socket 上读 sz 指定的字节数。如果读到了指定长度的字符串,它把这个字符串返回。如果连接断开导致字节数不够,将返回一个 false 加上读到的字符串。如果 sz 为 nil ,则返回尽可能多的字节数,但至少读一个字节(若无新数据,会阻塞)。
socket.write(id, str) 把一个字符串置入正常的写队列,skynet框架会在 socket 可写时发送它。
socket.close(id) 关闭一个连接,这个 API 有可能阻塞住执行流。因为如果有其它coroutine 正在阻塞读这个id对应的连接,会先驱使读操作结束,close操作才返回。

        socket.read中所谓的阻塞模式和 skynet.call一样,都利用了Lua的协程机制。调用socket.read,服务有可 能被挂起,直到接收到数据,才会往下执行。

        更多API参见:https://github.com/cloudwu/skynet/wiki/Socket

2、功能开发

        学完上面的API,我们来写一个Echo程序,Echo程序其实就是一个开启处理客户端消息的服务,它会把收到的内容原封不动地发回给客户端。以下是Echo程序的示意图:

 3、代码实现

        (1)主服务

         本例只需开启一个服务,在skynet/examples目录下创建main_echo.lua文件,输入代码如下所示:

local skynet = require "skynet"
local socket = require "skynet.socket"function connect(fd, addr)--启用连接print(fd.." connected addr:"..addr)socket.start(fd)--消息处理while true dolocal readdata = socket.read(fd)--正常接收if readdata ~= nil thenprint(fd.." recv "..readdata)socket.write(fd, readdata)--断开连接elseprint(fd.." close ")socket.close(fd)endend
endskynet.start(function()local listenfd = socket.listen("0.0.0.0", 8888)socket.start(listenfd ,connect)
end)

代码说明:

  1. 先引入skynetskynet.socket这两个模块;
  2. 使用skynet.start启动服务后,依次调用socket.listensocket.start来监听8888端口;
  3. 新客户端发起连接时,connect方法将被调用;
  4. while循环里,程序先用socket.read接收数据,如果收到数据(if readdata~=nil的真分
    支),则通过socket.write将数据发回客户端;如果客户端断开了连接 (if readdata~=nil的假分支),则调用socket.close关闭连接;
  5. “0.0.0.0”表示不限制客户端的IP。

(2)配置文件 

       skynet/examples目录下创建config_echo文件,也可以拿之前的配置文件修改"start"的值即可,配置参数如下所示: 

include "config.path"thread = 8
logger = nil
logpath = "."
harbor = 0
start = "main_echo"	-- main script
bootstrap = "snlua bootstrap"	-- The service for bootstrap
-- snax_interface_g = "snax_g"
cpath = root.."cservice/?.so"
-- daemon = "./skynet.pid"

4、运行代码

(1)输入如下指令即可运行:

  • cd skynet
  • ./skynet examples/config_echo

        如果开启服务端时提示“init service failed: ./lualib/skynet/socket.lua:414: Listen error”,意味着监听端口8888被占用,可能是多次运行服务端所致,可以执行“killall skynet”命令关闭所有的Skynet进程。

(2)重新打开终端输入命令,显示如下结果,表示运行成功;

(3)此时我们还需要开启一个telnet来作为我们的客户端去连接主服务,我们再打开一个终端输入指令“telnet 127.0.0.1 8888”

知识拓展:telnetLinux下的一个程序,可用于调试TCP连接。如果尚未安装,可执行apt-get install telnet”安装。输入“telnet [ip] [端口]”即可向指定服务器发起连接,连接成功后还可以在telnet中输入内容,按回车键可将字符串发 给服务端。

5、运行结果

当客户端连接成功后,主服务会收到一条外部访问的IP地址

 客户端输入了“hello”发送给服务端,服务器收到消息后再返回给客户端,如下图所示:


http://www.ppmy.cn/news/43933.html

相关文章

MySQL 8.0 OCP (1Z0-908) 考点精析-性能优化考点1:sys.statement_analysis视图

文章目录MySQL 8.0 OCP (1Z0-908) 考点精析-性能优化考点1:sys.statement_analysis视图视图sys.statement_analysis各列定义视图sys.statement_analysis视图的定义视图sys.statement_analysis各列解释例题例题解析参考MySQL 8.0 OCP (1Z0-908) 考点精析-性能优化考点…

Java实现输入行数打印取缔字符,打印金字塔三角形的两个代码程序

目录 前言 一、实现输入行数,打印取缔字符 1.1运行流程(思想) 1.2代码段 1.3运行截图 二、打印金字塔三角形 1.1运行流程(思想) 1.2代码段 1.3运行截图​​​​​​​ 前言 1.因多重原因,本博文有…

Linux基础篇(四)打包和解压

目录 一、打包和压缩 二、zip 和 unzip 三、tar指令 一、打包和压缩 1.是什么? 打包:将东西放到一起。 压缩:采用某种压缩算法,压缩它的存储空间。 2.为什么? 便于传输,或者归档&a…

丝滑的打包部署,一套带走~

以下文章来源于悟空聊架构 ,作者悟空聊架构 本文主要内容如下: 目录 一、背景 Docker打包部署方案 项目背景:新项目的后端框架是刚起步,搭建的是一套微服务框架,基础服务有网关 Gateway, Nacos 注册中心…

免费ChatGPT接入-国内怎么玩chatGPT

免费ChatGPT中文版 OpenAI 的 GPT 模型目前并不提供中文版的免费使用,但是有许多机器学习平台和第三方服务提供商也提供了基于 GPT 技术的中文版模型和 API。下面是一些常见的免费中文版 ChatGPT: Hugging Face:Hugging Face 是一个开源社区…

一文解决ethtool 原理介绍和解决网卡丢包排查思路

前言 之前记录过处理因为 LVS 网卡流量负载过高导致软中断发生丢包的问题,RPS 和 RFS 网卡多队列性能调优实践[1],对一般人来说压力不大的情况下其实碰见的概率并不高。这次想分享的话题是比较常见服务器网卡丢包现象排查思路,如果你是想了解…

这篇文章价值很大:股票历史分时成交数据怎么简单获取?【干货】

文章目录前言一、准备二、使用步骤1.引入库2,使用这个API查询历史分时数据:3.查询完整历史分时数据4.其他查询方法参数格式:[(市场代码, 股票代码), ...]参数:市场代码, 股票代码, 文件名, 起始位置, 数量参数:市场代码…

MVCC底层原理

目录说明MVCC的底层原理隐藏字段undo logRead View说明 在被面试官问面试题的时候,首先它问了Mysql的事务的隔离级别有几种?默认是哪种?他们分别解决了什么问题? 我在一顿回答“巴巴巴巴。。。。”之后,它又继续问题…