# 获取安装源
wget https://github.com/Bwar/NebulaBootstrap/archive/master.zip

# 解压安装包，给脚本加可执行权限
unzip master.zip; rm master.zip; mv NebulaBootstrap-master NebulaBootstrap; cd NebulaBootstrap; chmod u+x deploy.sh

# 一键安装
./deploy.sh --demo

# 配置Server ip地址
./configure.sh

# 启动Server
./startup.sh

# 测试一下
curl -H "Content-Type:application/json" -X POST -d '{"name": "Nebula", "address":"https://github.com/Bwar/Nebula"}' http://${your_ip}:15003/hello

#include "util/proctitle_helper.h"
#include "labor/Manager.hpp"

int main(int argc, char* argv[])
{
    if (argc != 2)
    {
        std::cerr << "para num error!" << std::endl;
        exit(-1);
    }
    ngx_init_setproctitle(argc, argv);
    neb::Manager oManager(argv[1]);
    oManager.Run();
    return(0);
}

// 设置程序名 
ngx_init_setproctitle(argc, argv);
// 定义Manager类实例
neb::Manager oManager(argv[1]);
//开始运行 
oManager.Run();

#ifndef MODULEHELLO_HPP_
#define MODULEHELLO_HPP_

#include <string>
#include <actor/cmd/Module.hpp>

namespace demo
{
class ModuleHello: public neb::Module, public neb::DynamicCreator<ModuleHello, std::string>
{
public:
    ModuleHello(const std::string& strModulePath);
    virtual ~ModuleHello();
    virtual bool Init();
    virtual bool AnyMessage(
                    std::shared_ptr<neb::SocketChannel> pUpstreamChannel,
                    const HttpMsg& oHttpMsg);
};
} /* namespace demo */

#endif /* MODULEHELLO_HPP_ */

#include "ModuleHello.hpp"
#include <util/json/CJsonObject.hpp>

namespace demo
{

ModuleHello::ModuleHello(const std::string& strModulePath)
    : neb::Module(strModulePath)
{
}

ModuleHello::~ModuleHello()
{
}

bool ModuleHello::Init()
{
    return(true);
}

bool ModuleHello::AnyMessage(
                std::shared_ptr<neb::SocketChannel> pUpstreamChannel,
                const HttpMsg& oInHttpMsg)
{
    HttpMsg oHttpMsg;
    neb::CJsonObject oResponseData;
    oHttpMsg.set_type(HTTP_RESPONSE);
    oHttpMsg.set_status_code(200);
    oHttpMsg.set_http_major(oInHttpMsg.http_major());
    oHttpMsg.set_http_minor(oInHttpMsg.http_minor());
    oResponseData.Add("code", 0);
    oResponseData.Add("msg", "hello!");
    oHttpMsg.set_body(oResponseData.ToFormattedString());
    SendTo(pUpstreamChannel, oHttpMsg);
    return(true);
}

} /* namespace demo */