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

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. class INetEvent : public NetEvent 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3. public: 
    4. 
  
  
  
  4.   virtual void onAccept(NetConnect * conn){} 
    5. 
  
  
  
  5.   virtual void onClose(NetConnect * conn){} 
    6. 
  
  
  
  6.   virtual void onMsg(NetConnect * conn, int msgtype, NetPacket * pack){} 
    7. 
  
  
  
  7. }; 
    8. 
  
  
  
  8.  
    9. 
  
  
  
  9. int main() 
    10. 
  
  
  
  10. { 
    11. 
  
  
  
  11.   EventLoop::Instance()->init(); 
    12. 
  
  
  
  12.  
    13. 
  
  
  
  13.   INetEvent eve; 
    14. 
  
  
  
  14.   NetServer server(EventLoop::Instance(), &eve); 
    15. 
  
  
  
  15.   server.listen("127.0.0.1", 3001); 
    16. 
  
  
  
  16.  
    17. 
  
  
  
  17.   return EventLoop::Instance()->run(); 
    18. 
  
  
  
  18. } 
    19.

创建一个kcp服务器

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

 
 
 
    
  
  
  
  1. class KNetEvent : public KcpEvent 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3. public: 
    4. 
  
  
  
  4.   virtual void onAccept(KcpSession * conn){}; 
    5. 
  
  
  
  5.   virtual void onClose(KcpSession * conn){}; 
    6. 
  
  
  
  6.   virtual void onMsg(KcpSession * conn, int msgtype, UdpPacket * pack){} 
    7. 
  
  
  
  7.   virtual void onUdpTimeout(KcpSession * s){} 
    8. 
  
  
  
  8. }; 
    9. 
  
  
  
  9.  
    10. 
  
  
  
  10. int main() 
    11. 
  
  
  
  11. { 
    12. 
  
  
  
  12.   EventLoop::Instance()->init(); 
    13. 
  
  
  
  13.  
    14. 
  
  
  
  14.   KNetEvent eve; 
    15. 
  
  
  
  15.   KcpServer server(EventLoop::Instance(), &eve); 
    16. 
  
  
  
  16.   server.start("127.0.0.1", 3001); 
    17. 
  
  
  
  17.  
    18. 
  
  
  
  18.   return EventLoop::Instance()->run(); 
    19. 
  
  
  
  19. } 
    20.

创建一个websocket服务器

自动完成解析websocket协议工作

 
 
 
    
  
  
  
  1. class IWebEvent : public WebSocketEvent 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3. public: 
    4. 
  
  
  
  4.   virtual void onHandshake(WebSocketConnect * conn){}; 
    5. 
  
  
  
  5.   virtual void onAccept(WebSocketConnect * conn){}; 
    6. 
  
  
  
  6.   virtual void onClose(WebSocketConnect * conn){}; 
    7. 
  
  
  
  7.   virtual void onMsg(WebSocketConnect * conn, WebSocketPacket * pack){}; 
    8. 
  
  
  
  8. }; 
    9. 
  
  
  
  9.  
    10. 
  
  
  
  10. int main() 
    11. 
  
  
  
  11. { 
    12. 
  
  
  
  12.   EventLoop::Instance()->init(); 
    13. 
  
  
  
  13.  
    14. 
  
  
  
  14.   IWebEvent wevent; 
    15. 
  
  
  
  15.   WebSocketServer server(EventLoop::Instance(), &wevent); 
    16. 
  
  
  
  16.   server.listen("127.0.0.1", 8080); 
    17. 
  
  
  
  17.  
    18. 
  
  
  
  18.   return EventLoop::Instance()->run(); 
    19. 
  
  
  
  19. } 
    20.

创建一个http服务器

http仅支持简单的get post请求

 
 
 
    
  
  
  
  1. const char * html = R"( 
    2. 
  
  
  
  2.  
    3. 
  
  
  
  3. login
     
    4. 
  
  
  
  4. hello world!
     
    5. 
  
  
  
  5.    
    6. 
  
  
  
  6.      
    7. 
  
  
  
  7.      
    8. 
  
  
  
  8.      
    9. 
  
  
  
  9.    
    10. 
  
  
  
  10.  
    11. 
  
  
  
  11. )"; 
    12. 
  
  
  
  12.    
    13. 
  
  
  
  13. const char * succeed = "" 
    14. 
  
  
  
  14. "" 
    15. 
  
  
  
  15. "" 
    16. 
  
  
  
  16. "
    login succeed
    " 
    17. 
  
  
  
  17. "" 
    18. 
  
  
  
  18. ""; 
    19. 
  
  
  
  19.  
    20. 
  
  
  
  20. const char * failing = "" 
    21. 
  
  
  
  21. "" 
    22. 
  
  
  
  22. "" 
    23. 
  
  
  
  23. "
    login failing
    " 
    24. 
  
  
  
  24. "" 
    25. 
  
  
  
  25. ""; 
    26. 
  
  
  
  26.  
    27. 
  
  
  
  27. int main() 
    28. 
  
  
  
  28. { 
    29. 
  
  
  
  29.   EventLoop::Instance()->init(); 
    30. 
  
  
  
  30.   HttpServer server(EventLoop::Instance()); 
    31. 
  
  
  
  31.   server.listen("127.0.0.1", 80); 
    32. 
  
  
  
  32.  
    33. 
  
  
  
  33.   server.addGet("/", [](HttpConnect *conn, std::string_view & data) { 
    34. 
  
  
  
  34.     conn->autoMsg(html); 
    35. 
  
  
  
  35.   }); 
    36. 
  
  
  
  36.  
    37. 
  
  
  
  37.   server.addPost("/login", [](HttpConnect *conn, std::string_view & data) { 
    38. 
  
  
  
  38.     HttpParam hp(data); 
    39. 
  
  
  
  39.     if (hp.getStr("user") == "jw" && hp.getStr("pass") == "1111") 
    40. 
  
  
  
  40.     { 
    41. 
  
  
  
  41.       conn->autoMsg(succeed); 
    42. 
  
  
  
  42.     } 
    43. 
  
  
  
  43.     else 
    44. 
  
  
  
  44.     { 
    45. 
  
  
  
  45.       conn->autoMsg(failing); 
    46. 
  
  
  
  46.     } 
    47. 
  
  
  
  47.   }); 
    48. 
  
  
  
  48.  
    49. 
  
  
  
  49.   return EventLoop::Instance()->run(); 
    50. 
  
  
  
  50. } 
    51.

mysql和线程池

这次我们用lua示例：

 
 
 
    
  
  
  
  1. local config = DBConfig:new() 
    2. 
  
  
  
  2. config.device = "mysql" 
    3. 
  
  
  
  3. config.ip = "127.0.0.1" 
    4. 
  
  
  
  4. config.dbname = "jw_test" 
    5. 
  
  
  
  5. config.user = "root" 
    6. 
  
  
  
  6. config.pswd = "1111" 
    7. 
  
  
  
  7. config.port = 3306 
    8. 
  
  
  
  8.  
    9. 
  
  
  
  9. pool = DBThreadPool:new(config) 
    10. 
  
  
  
  10. pool:create(1) 
    11. 
  
  
  
  11.  
    12. 
  
  
  
  12. func = function(err, result) 
    13. 
  
  
  
  13.   while(result:fetch()) 
    14. 
  
  
  
  14.   do 
    15. 
  
  
  
  15.     local id = result:getInt32() 
    16. 
  
  
  
  16.     local num = result:getInt32() 
    17. 
  
  
  
  17.     local name = result:getString() 
    18. 
  
  
  
  18.  
    19. 
  
  
  
  19.     local str = "id:" .. id .. ", num:" .. num .. ", name:" .. name 
    20. 
  
  
  
  20.     print(str) 
    21. 
  
  
  
  21.   end 
    22. 
  
  
  
  22. end 
    23. 
  
  
  
  23.  
    24. 
  
  
  
  24. function exec() 
    25. 
  
  
  
  25.   local sql = SqlCommand:new("select * from test where id = ?") 
    26. 
  
  
  
  26.   sql:pushInt32(1) 
    27. 
  
  
  
  27.   sql:addToPool(pool, func) 
    28. 
  
  
  
  28. end 
    29. 
  
  
  
  29.  
    30. 
  
  
  
  30. event_init() 
    31. 
  
  
  
  31. exec() 
    32. 
  
  
  
  32. timer = UTimer:new() 
    33. 
  
  
  
  33. timer:start(function () 
    34. 
  
  
  
  34.     pool:update() 
    35. 
  
  
  
  35.   end, 10, 10) 
    36. 
  
  
  
  36. event_run() 
    37.

任意扩展进程节点

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

base进程 cell进程 db进程
start engine.exe base.luastart engine.exe cell.luastart engine.exe db.lua

提供一个serialization序列化工具

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

 
 
 
    
  
  
  
  1. struct testmsg 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3.   int32 x 
    4. 
  
  
  
  4.   int32 y 
    5. 
  
  
  
  5.   int32 z 
    6. 
  
  
  
  6.   int8 state 
    7. 
  
  
  
  7.   vector vec 
    8. 
  
  
  
  8.    
    9. 
  
  
  
  9.   read{ 
    10. 
  
  
  
  10.     [x, y, z, state] 
    11. 
  
  
  
  11.     if(state == 1) 
    12. 
  
  
  
  12.     { 
    13. 
  
  
  
  13.       [vec] 
    14. 
  
  
  
  14.     } 
    15. 
  
  
  
  15.   } 
    16. 
  
  
  
  16.   write{ 
    17. 
  
  
  
  17.     [x, y, z, state, vec] 
    18. 
  
  
  
  18.   } 
    19. 
  
  
  
  19. } 
    20.

通过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 测试通过

新闻名称：一个开源的服务器框架，特别适用于开发小游戏
当前URL：http://www.csdahua.cn/qtweb/news28/435778.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

python知识

分类信息网

上市集团网站建设　　 　云虚拟主机　　 　青羊雕琢时光　　 　马边网站建设　　 　娃娃鱼鱼苗　　 　广汉优化推广　　 　成都托管服务器　　 　成都微信小程序开发　　 　茶叶批发零售　　 　成都虚拟主机　　 　成都响应式网站建设　　 　成都茶叶销售　　 　成都免费自助建站　　 　网络推广　　 　软文营销　　 　成都展柜设计　　 　水泥搅拌车　　 　响应式网站　　 　都江堰做网站　　 　户外广告设计