Subevent

C++ Event Driven and Network Application Library

Features

• Event driven App/Thread.
• Async TCP/UDP client and server.
• Async HTTP/HTTPS client and server.
• Async WebSocket client and server.
• Multiple connections in single thread.
• Header only.
• Easy to use.

Requirements

• C++11 or later
• Linux, Windows, macOS
• OpenSSL ( if use secure protocol (https, wss) )

Compile Options

• -std=c++11 (or later option)
• -pthread or -lpthread
• -lssl and -lcrypt (for OpenSSL)

Example

• Simple Application

#include <subevent/subevent.hpp>

SEV_USING_NS

//---------------------------------------------------------------------------//
// Main
//---------------------------------------------------------------------------//

SEV_IMPL_GLOBAL

int main(int, char**)
{
    NetApplication app;

    // your code here.

    return app.run();
}

• Custom Application Class

#include <subevent/subevent.hpp>

SEV_USING_NS

//---------------------------------------------------------------------------//
// MyApp
//---------------------------------------------------------------------------//

class MyApp : public NetApplication
{
protected:
    bool onInit() override
    {
        NetApplication::onInit();

        // Your initialization code here.

        return true;
    }

    void onExit() override
    {
        // Your deinitialization code here.

        NetApplication::onExit();
    }
};

//---------------------------------------------------------------------------//
// Main
//---------------------------------------------------------------------------//

SEV_IMPL_GLOBAL

int main(int, char**)
{
    MyApp app;
    return app.run();
}

• How to End MyApp

// call "void NetApplication::stop()"
stop();

• Thread

class MyThread : public NetThread
{
protected:
    bool onInit() override
    {
        NetThread::onInit();

        // Your initialization code here.

        return true;
    }

    void onExit() override
    {
        // Your deinitialization code here.

        NetThread::onExit();
    }
};

// Start
MyThread* myThread = new MyThread();
myThread->start();

// End
myThread->stop();
myThread->wait();
delete myThread;

• Event Send/Receive

// Declare MyEvent
// <Unique Id, ParamType1, ParamType2, ...>
typedef UserEvent<1, int, std::string> MyEvent;

// Send (to another thread or self)
int param1 = 20;
std::string param2 = "data";
myThread->post(new MyEvent(param1, param2));

// Receive
setUserEventHandler<MyEvent>([&](const MyEvent* myEvent) {
    int param1;
    std::string param2;
    myEvent->getParams(param1, param2);
});

• Async Task

myThread->post([&]() {
    // Executed on myThread.
});

• Timer

Timer* timer = new Timer();

uint32_t msec = 60000;
bool repeat = false;

// start
timer->start(msec, repeat, [&](Timer*) {
    // Called from the same thread when time out.
});

• Network
  Please see the files under subevent/examples/ directory.
  To build on Linux.
  In each directory:

$ cmake .
$ make

TODO

• HTTP/2
• etc