手机版
吊床厂家
免费服务热线

Free service

hotline

010-00000000
吊床厂家
热门搜索：
成功案例
当前位置：首页 > 成功案例

看一看：一个开源的服务器框架，特别适用于开发小游戏

发布时间：2022-03-31 16:23:13 阅读：次 来源：吊床厂家
一个开源的服务器框架，特别适用于开发小游戏 作者：佚名 2021-03-08 10:21:22 开发 前端 一个跨平台的c++<->lua服务器快速解决方案，该框架即可快速响应服务器开发工作，设计思想：“让事情变得更简单”

jwEngine

一个跨平台的c++<->lua服务器快速解决方案，该框架即可快速响应服务器开发工作，设计思想：,让事情变得更简单

网络底层采用libuv（node.js底层库），异步io助力使单线程也能释放澎湃动力，跨平台支持epoll、iocp、ipv6。框架支持tcp、udp/kcp、websocket、http，并保证了接口的一致性，使用了sol2将所有接口都导出到lua，可以选择用lua开发逻辑。

使用modern c++开发，尽可能的使用std::move、std::string_view减少内存复制。

该框架使用异步事件，不建议使用多线程，避免多线程上下文切换开销和破坏代码美感，网络部分和逻辑部分使用一个主事件循环驱动。建议的方案是多进程单线程的横向扩展，按照业务控制各个进程的粒度，当然mysql和redis可以加入到线程池中。

创建一个tcp服务器

只需要简单几行代码即可创建一个tcp高性能服务器，并自动处理数据包头和粘包（其中包头包含消息长度和协议号），构建一个完好的NetPacket交给你。

  1. classINetEvent:publicNetEvent
  2. {
  3. public:
  4. virtualvoidonAccept(NetConnect*conn){}
  5. virtualvoidonClose(NetConnect*conn){}
  6. virtualvoidonMsg(NetConnect*conn,intmsgtype,NetPacket*pack){}
  7. };
  9. intmain()
  10. {
  11. EventLoop::Instance()->init();
  13. INetEventeve;
  14. NetServerserver(EventLoop::Instance(),&eve);
  15. server房子强拆可以报警吗.listen("127.0.0.1",3001);
  17. returnEventLoop::Instance()->run();
  18. }
创建一个kcp服务器

c++的kcp服务器示例，快速构建你的帧同步服务器，保证消息的可靠性

  1. classKNetEvent:publicKcpEvent
  2. {
  3. public:
  4. virtualvoidonAccept(KcpSession*conn){};
  5. virtualvoidonClose(KcpSession*conn){};
  6. virtualvoidonMsg(KcpSession*conn,intmsgtype,UdpPacket*pack){}
  7. virtualvoidonUdpTimeout(KcpSession*s){}
  8. };
  10. intmain()
  11. {
  12. EventLoop::Instance()->init();
  14. KNetEventeve;
  15. KcpServerserver(EventLoop::Instance(),&eve);
  16. server.start("127.0.0.1",3001);
  18. returnEventLoop::Instance()->run();
  19. }
创建一个websocket服务器

自动完成解析websocket协议工作

  1. classIWebEvent:publicWebSocketEvent
  2. {
  3. public:
  4. virtualvoidonHandshake(WebSocketConnect*conn){};
  5. virtualvoidonAccept(WebSocketConnect*conn){};
  6. virtualvoidonClose(WebSocketConnect*conn){};
  7. virtualvoidonMsg(WebSocketConnect*conn,WebSocketPacket*pack){};
  8. };
  10. intmain()
  11. {
  12. EventLoop::Instance()->init();
  14. IWebEventwevent;
  15. WebSocketServerserver(EventLoop::Instance(),&wevent);
  16. server.listen("127.0.0.1",8080);
  18. returnEventLoop::Instance()->run();
  19. }
创建一个http服务器

http仅支持简单的get post请求

  1. constchar*html=R"(<html>
  2. <body>
  3. <h1>login</h1>
  4. <p>helloworld!</p>
  5. <formaction="login"method="post">
  6. <inputtype="text"name="user"/>
  7. <inputtype="password"name="pass"/>
  8. <inputtype="submit"value="login"/>
  9. </form>
  10. </body>
  11. </html>)";
  13. constchar*succeed=""
  14. "<html>"
  15. "<body>"
  16. "<h1>loginsucceed</h1>"
  17. "</body>"
  18. "</html>";
  20. constchar*failing=""
  21. "<html>"
  22. "<body>"
  23. "<h1>loginfailing</h1>"
  24. "</body>"
  25. "</html>";
  27. intmain()
  28. {
  29. EventLoop::Instance()->init();
  30. HttpServerserver(EventLoop::Instance());
  31. server.listen("127.0.0.1",80);
  33. server.addGet("/",[](HttpConnect*conn,std::string_view&data){
  34. conn->autoMsg(html);
  35. });
  37. server.addPost("/login",[](HttpConnect*conn,std::string_view&data){
  38. HttpParamhp(data);
  39. if(hp.getStr("user")=="jw"&&hp.getStr("pass")=="1111")
  40. {
  41. conn->autoMsg(succeed);
  42. }
  43. else
  44. {
  45. conn->autoMsg(failing);
  46. }
  47. });
  49. returnEventLoop::Instance()->run();
  50. }
mysql和线程池

这次我们用lua示例：

  1. localconfig=DBConfig:new()
  2. config.device="mysql"
  3. config.ip="127.0.0.1"
  4. config.dbname="jw_test"
  5. config.user="root"
  6. config.pswd="1111"
  7. config.port=3306
  9. pool=DBThreadPool:new(config)
  10. pool:create(1)
  12. func=function(err,result)
  13. while(result:fetch())
  14. do
  15. localid=result:getInt32()
  16. localnum=result:getInt32()
  17. localname=result:getString()
  19. localstr="id:"..id..",num:"..num..",name:"..name
  20. print(str)
  21. end
  22. end
  24. functionexec()
  25. localsql=SqlCommand:new("select*fromtestwhereid=?")
  26. sql:pushInt32(1)
  27. sql:addToPool(pool,func)
  28. end
  30. event_init()
  31. exec()
  32. timer=UTimer:new()
  33. timer:start(function()
  34. pool:update()
  35. end,10,10)
  36. event_run()
任意扩展进程节点

你可以任意扩展你的进程，示例：

base进程 cell进程 db进程 start engine.exe base.lua start engine.exe cell.lua start engine.exe db拆迁不给钱怎么回事.lua 提供一个serialization序列化工具

类似于c++的语法，写起来非常简单，示例：

  1. structtestmsg
  2. {
  3. int32x
  4. int32y
  5. int32z
  6. int8state
  7. vector<int32>vec
  9. read{
  10. [x,y,z,state]
  11. if(state==1)
  12. {
  13. [vec]
  14. }
  15. }
  16. write{
  17. [x,y,z,state,vec]
  18. }
  19. }

通过serialization工具可以将协议的描述文件生成c++和lua代码，自动生成read()和write()的函数实现，使得数据结构快速映射到SocketBuffer中。

目前serialization序列化工具为实验性，可能是脆弱的，建议使用更强大的protobuf。该项目已集成lua-protobuf，使得c++和lua之间的协议无缝衔接。

lua-protobuf的开源地址：lua-protobuf

这个示例展示了c++客户端和lua服务器之间的通讯：快速搭建服务器Demo

构建

你需要一个modern c++17编译器

  • vs2017 测试通过
  • gcc version 9.3.0 测试通过

相关阅读