文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

怎么使用jwEngine框架

2024-04-02 19:55

关注

本篇文章为大家展示了怎么使用jwEngine框架,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

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交给你。

class INetEvent : public NetEvent { public:   virtual void onAccept(NetConnect * conn){}   virtual void onClose(NetConnect * conn){}   virtual void onMsg(NetConnect * conn, int msgtype, NetPacket * pack){} };  int main() {   EventLoop::Instance()->init();    INetEvent eve;   NetServer server(EventLoop::Instance(), &eve);   server.listen("127.0.0.1", 3001);    return EventLoop::Instance()->run(); }

创建一个kcp服务器

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

class KNetEvent : public KcpEvent { public:   virtual void onAccept(KcpSession * conn){};   virtual void onClose(KcpSession * conn){};   virtual void onMsg(KcpSession * conn, int msgtype, UdpPacket * pack){}   virtual void onUdpTimeout(KcpSession * s){} };  int main() {   EventLoop::Instance()->init();    KNetEvent eve;   KcpServer server(EventLoop::Instance(), &eve);   server.start("127.0.0.1", 3001);    return EventLoop::Instance()->run(); }

创建一个websocket服务器

自动完成解析websocket协议工作

class IWebEvent : public WebSocketEvent { public:   virtual void onHandshake(WebSocketConnect * conn){};   virtual void onAccept(WebSocketConnect * conn){};   virtual void onClose(WebSocketConnect * conn){};   virtual void onMsg(WebSocketConnect * conn, WebSocketPacket * pack){}; };  int main() {   EventLoop::Instance()->init();    IWebEvent wevent;   WebSocketServer server(EventLoop::Instance(), &wevent);   server.listen("127.0.0.1", 8080);    return EventLoop::Instance()->run(); }

创建一个http服务器

http仅支持简单的get post请求

const char * html = R"(<html> <body> <h2>login</h2> <p>hello world!</p>   <form action="login" method="post">     <input type="text" name="user"/>     <input type="password" name="pass"/>     <input type="submit" value="login"/>   </form> </body> </html>)";    const char * succeed = "" "<html>" "<body>" "<h2>login succeed</h2>" "</body>" "</html>";  const char * failing = "" "<html>" "<body>" "<h2>login failing</h2>" "</body>" "</html>";  int main() {   EventLoop::Instance()->init();   HttpServer server(EventLoop::Instance());   server.listen("127.0.0.1", 80);    server.addGet("/", [](HttpConnect *conn, std::string_view & data) {     conn->autoMsg(html);   });    server.addPost("/login", [](HttpConnect *conn, std::string_view & data) {     HttpParam hp(data);     if (hp.getStr("user") == "jw" && hp.getStr("pass") == "1111")     {       conn->autoMsg(succeed);     }     else     {       conn->autoMsg(failing);     }   });    return EventLoop::Instance()->run(); }

mysql和线程池

这次我们用lua示例:

local config = DBConfig:new() config.device = "mysql" config.ip = "127.0.0.1" config.dbname = "jw_test" config.user = "root" config.pswd = "1111" config.port = 3306  pool = DBThreadPool:new(config) pool:create(1)  func = function(err, result)   while(result:fetch())   do     local id = result:getInt32()     local num = result:getInt32()     local name = result:getString()      local str = "id:" .. id .. ", num:" .. num .. ", name:" .. name     print(str)   end end  function exec()   local sql = SqlCommand:new("select * from test where id = ?")   sql:pushInt32(1)   sql:addToPool(pool, func) end  event_init() exec() timer = UTimer:new() timer:start(function ()     pool:update()   end, 10, 10) event_run()

任意扩展进程节点

你可以任意扩展你的进程,示例:

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

提供一个serialization序列化工具

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

struct testmsg {   int32 x   int32 y   int32 z   int8 state   vector<int32> vec      read{     [x, y, z, state]     if(state == 1)     {       [vec]     }   }   write{     [x, y, z, state, vec]   } }

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

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

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

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

构建

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

上述内容就是怎么使用jwEngine框架,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注编程网行业资讯频道。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯