sf_msg_bus_server.h

/**
* @version 1.0.0
* @author skyfire
* @mail skyfireitdiy@hotmail.com
* @see http://github.com/skyfireitdiy/sflib
* @file sf_msg_bus_server.h

* sflib第一版本发布
* 版本号1.0.0
* 发布日期：2018-10-22
*/

/*
 * sf_msg_bus_server 消息总线服务器
 */

#pragma once

#include <string>

#include "sf_msg_bus_utils.h"
#include "sf_type.hpp"
#include "sf_object.hpp"
#include "sf_tcp_server.hpp"
#include "sf_serialize_binary.hpp"

namespace skyfire {

    /**
     *  @brief 消息总线服务端
     */
    class sf_msg_bus_server : public sf_nocopy<sf_object> {
        /**
         * @brief msg_come 消息到来信号
         */
    SF_REG_SIGNAL(msg_come, SOCKET, std::string, byte_array);

    public:

        /**
         * @brief make_server 创建消息总线服务器
         * @return 消息总线服务器对象
         */
        static std::shared_ptr<sf_msg_bus_server> make_server();

        /**
         * @brief sf_msg_bus_server 构造函数
         */
        sf_msg_bus_server();
        /**
         * 析构函数
         */
        ~sf_msg_bus_server();

        /**
         * @brief listen 监听消息总线
         * @param ip ip
         * @param port 端口
         * @return 监听是否成功
         */
        bool listen(const std::string &ip, unsigned short port);

        /**
         * @brief close 关闭总线服务器
         */
        void close();

        /**
         * @brief clear_client 清理客户端
         */
        void clear_client();

        /**
         * @brief send_msg 发送消息
         * @param type 类型
         * @param data 数据
         */
        void send_msg(const std::string &type, const byte_array &data);

        /**
         * 获取服务器地址
         * @param addr 地址信息
         * @return 是否成功
         */
        bool get_server_addr(sf_addr_info_t &addr);

    private:
        std::shared_ptr<sf_tcp_server> p_server__ = sf_tcp_server::make_server();

        std::map<std::string, std::list<SOCKET>> msg_map__;

        void reg_msg__(SOCKET sock, const std::string &msg_name);

        void on_reg_data__(SOCKET sock, const sf_pkg_header_t &header, const byte_array &data);

        void unreg_msg__(SOCKET sock, const std::string &msg);

        void on_disconnect__(SOCKET sock);

    };
}