Merge branch 'master' of github.com:ZLMediaKit/ZLMediaKit

81747d11 · ziyue · cd1ca2c1 · 8c30f11c · 81747d11 · 81747d11
Commit 81747d11 authored Feb 09, 2022 by ziyue
--- a/.clang-format
+++ b/.clang-format
@@ -27,7 +27,25 @@ AllowShortFunctionsOnASingleLine: Inline
 # 模板声明换行
 AlwaysBreakTemplateDeclarations: Yes
 # 左开括号不换行
-BreakBeforeBraces: Attach
+BreakBeforeBraces: Custom
+BraceWrapping:
+  AfterCaseLabel: false
+  AfterClass: false
+  # BraceWrappingAfterControlStatementStyle: MultiLine
+  AfterEnum: false
+  AfterFunction: false
+  AfterNamespace: false
+  AfterStruct: false
+  AfterUnion: false
+  AfterExternBlock: false
+  BeforeCatch: false
+  BeforeElse: false
+  BeforeLambdaBody: false
+  BeforeWhile: false
+  IndentBraces: false
+  SplitEmptyFunction: false
+  SplitEmptyRecord: false
+  SplitEmptyNamespace: false
 # 构造函数初始化时在 `,` 前换行, 和 `:` 对齐显得整齐
 BreakConstructorInitializers: BeforeComma
 # 继承过长需要换行时也在 `,` 前

--- a/.github/workflows/ccpp.yml
+++ b/.github/workflows/ccpp.yml
-name: C/C++ CI
+name: linux C/C++ CI
 on: [push]

--- a/.github/workflows/macos.yml
+++ b/.github/workflows/macos.yml
+name: macos C/C++ CI
+on: [push]
+jobs:
+  build:
+    runs-on: macOS-latest
+    steps:
+    - uses: actions/checkout@v1
+    - name: 下载submodule源码
+      run: git submodule update --init
+#    - name: 安装brew
+#      run: ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)"
+#
+#    - name: brew安装依赖库(非必选)
+#      run: brew update && brew install cmake openssl sdl2 ffmpeg
+#    - name: 下载 SRTP
+#      uses: actions/checkout@v2
+#      with:
+#        repository: cisco/libsrtp
+#        fetch-depth: 1
+#        ref: v2.3.0
+#        path: 3rdpart/libsrtp
+#
+#    - name: 编译 SRTP
+#      run: cd 3rdpart/libsrtp && ./configure --enable-openssl && make -j4 && sudo make install
+    - name: 编译
+      run: mkdir -p build && cd build && cmake .. && make -j4
+    - name: 运行MediaServer
+      run: pwd && cd release/linux/Debug && sudo ./MediaServer -d &
--- a/ZLToolKit @ 40c09a48
+++ b/ZLToolKit @ 40c09a48
-Subproject commit 25062620233c62475aaffc0a9960e2689d8418ce
+Subproject commit 40c09a4865026de94cdc1ad874aeba580bf15fdf
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -25,6 +25,18 @@ if (CMAKE_SYSTEM_NAME MATCHES "Linux")
    SET(LIBRARY_OUTPUT_PATH ${RELEASE_DIR}/linux/${CMAKE_BUILD_TYPE})
    SET(EXECUTABLE_OUTPUT_PATH ${RELEASE_DIR}/linux/${CMAKE_BUILD_TYPE})
    add_compile_options(-fPIC -Wall -Wno-unused-variable -Wno-unused-value)
+    INCLUDE(CheckCXXSourceCompiles)
+    file(READ ${CMAKE_CURRENT_SOURCE_DIR}/cmake/checks/atomic_check.cpp atomic_check_cpp)
+    CHECK_CXX_SOURCE_COMPILES("${atomic_check_cpp}" HAVE_CXX_ATOMICS_WITHOUT_LIB)
+    if(NOT HAVE_CXX_ATOMICS_WITHOUT_LIB)
+        list(APPEND CMAKE_REQUIRED_LIBRARIES "atomic")
+        CHECK_CXX_SOURCE_COMPILES("${atomic_check_cpp}" HAVE_CXX_ATOMICS_WITH_LIB)
+        if(NOT HAVE_CXX_ATOMICS_WITH_LIB)
+            message(WARNING "Compiler doesn't support std::atomic<long long>")
+        else()
+            set(CMAKE_CXX_LINK_FLAGS "${CMAKE_CXX_LINK_FLAGS} -latomic")
+        endif()
+    endif()
 elseif (CMAKE_SYSTEM_NAME MATCHES "Windows")
    if (CMAKE_CL_64)
        set(CL_32_64 64)

--- a/api/source/mk_events.cpp
+++ b/api/source/mk_events.cpp
@@ -14,6 +14,8 @@
 #include "Http/HttpSession.h"
 #include "Rtsp/RtspSession.h"
 #include "Record/MP4Recorder.h"
+using namespace toolkit;
 using namespace mediakit;
 static void* s_tag;

--- a/api/source/mk_events_objects.cpp
+++ b/api/source/mk_events_objects.cpp
@@ -16,6 +16,8 @@
 #include "Http/HttpBody.h"
 #include "Http/HttpClient.h"
 #include "Rtsp/RtspSession.h"
+using namespace toolkit;
 using namespace mediakit;
 ///////////////////////////////////////////RecordInfo/////////////////////////////////////////////
@@ -247,7 +249,7 @@ API_EXPORT mk_http_body API_CALL mk_http_body_from_string(const char *str, size_
    if(!len){
        len = strlen(str);
    }
-    return new HttpBody::Ptr(new HttpStringBody(string(str,len)));
+    return new HttpBody::Ptr(new HttpStringBody(std::string(str, len)));
 }
 API_EXPORT mk_http_body API_CALL mk_http_body_from_file(const char *file_path){

--- a/api/source/mk_h264_splitter.cpp
+++ b/api/source/mk_h264_splitter.cpp
@@ -15,7 +15,7 @@ using namespace mediakit;
 class H264Splitter : public HttpRequestSplitter {
 public:
-    using onH264 = function<void(const char *data, size_t len)>;
+    using onH264 = std::function<void(const char *data, size_t len)>;
    H264Splitter() = default;
    ~H264Splitter() override;
    void setOnSplitted(onH264 cb);

--- a/api/source/mk_proxyplayer.cpp
+++ b/api/source/mk_proxyplayer.cpp
@@ -29,7 +29,7 @@ API_EXPORT void API_CALL mk_proxy_player_release(mk_proxy_player ctx) {
 API_EXPORT void API_CALL mk_proxy_player_set_option(mk_proxy_player ctx, const char *key, const char *val){
    assert(ctx && key && val);
    PlayerProxy::Ptr &obj = *((PlayerProxy::Ptr *) ctx);
-    string key_str(key),val_str(val);
+    std::string key_str(key), val_str(val);
    obj->getPoller()->async([obj,key_str,val_str](){
        //切换线程再操作
        (*obj)[key_str] = val_str;
@@ -39,7 +39,7 @@ API_EXPORT void API_CALL mk_proxy_player_set_option(mk_proxy_player ctx, const c
 API_EXPORT void API_CALL mk_proxy_player_play(mk_proxy_player ctx, const char *url) {
    assert(ctx && url);
    PlayerProxy::Ptr &obj = *((PlayerProxy::Ptr *) ctx);
-    string url_str(url);
+    std::string url_str(url);
    obj->getPoller()->async([obj,url_str](){
        //切换线程再操作
        obj->play(url_str);

--- a/api/source/mk_pusher.cpp
+++ b/api/source/mk_pusher.cpp
@@ -11,6 +11,8 @@
 #include <assert.h>
 #include "mk_pusher.h"
 #include "Pusher/MediaPusher.h"
+using namespace toolkit;
 using namespace mediakit;
 API_EXPORT mk_pusher API_CALL mk_pusher_create(const char *schema,const char *vhost,const char *app, const char *stream){
@@ -35,7 +37,7 @@ API_EXPORT void API_CALL mk_pusher_release(mk_pusher ctx){
 API_EXPORT void API_CALL mk_pusher_set_option(mk_pusher ctx, const char *key, const char *val){
    assert(ctx && key && val);
    MediaPusher::Ptr &obj = *((MediaPusher::Ptr *)ctx);
-    string key_str(key),val_str(val);
+    std::string key_str(key), val_str(val);
    obj->getPoller()->async([obj,key_str,val_str](){
        //切换线程再操作
        (*obj)[key_str] = val_str;
@@ -45,7 +47,7 @@ API_EXPORT void API_CALL mk_pusher_set_option(mk_pusher ctx, const char *key, co
 API_EXPORT void API_CALL mk_pusher_publish(mk_pusher ctx,const char *url){
    assert(ctx && url);
    MediaPusher::Ptr &obj = *((MediaPusher::Ptr *)ctx);
-    string url_str(url);
+    std::string url_str(url);
    obj->getPoller()->async([obj,url_str](){
        //切换线程再操作
        obj->publish(url_str);

--- a/api/source/mk_tcp.cpp
+++ b/api/source/mk_tcp.cpp
@@ -13,6 +13,8 @@
 #include "mk_tcp_private.h"
 #include "Http/WebSocketClient.h"
 #include "Http/WebSocketSession.h"
+using namespace toolkit;
 using namespace mediakit;
 API_EXPORT const char* API_CALL mk_sock_info_peer_ip(const mk_sock_info ctx, char *buf){
@@ -62,19 +64,19 @@ API_EXPORT void API_CALL mk_tcp_session_send(const mk_tcp_session ctx,const char
 API_EXPORT void API_CALL mk_tcp_session_send_safe(const mk_tcp_session ctx,const char *data,size_t len){
    assert(ctx && data);
-    if(!len){
+    if (!len) {
        len = strlen(data);
    }
    try {
-        weak_ptr<TcpSession> weak_session = ((TcpSessionForC *)ctx)->shared_from_this();
+        std::weak_ptr<TcpSession> weak_session = ((TcpSessionForC *)ctx)->shared_from_this();
-        string str = string(data,len);
+        std::string str = std::string(data,len);
        ((TcpSessionForC *)ctx)->async([weak_session,str](){
            auto session_session = weak_session.lock();
            if(session_session){
                session_session->SockSender::send(str);
            }
        });
-    }catch (std::exception &ex){
+    } catch (std::exception &ex) {
        WarnL << "can not got the strong pionter of this mk_tcp_session:" << ex.what();
    }
 }
@@ -208,13 +210,13 @@ TcpClientForC::Ptr *mk_tcp_client_create_l(mk_tcp_client_events *events, mk_tcp_
        case mk_type_tcp:
            return new TcpClientForC::Ptr(new TcpClientForC(events));
        case mk_type_ssl:
-            return (TcpClientForC::Ptr *)new shared_ptr<TcpSessionWithSSL<TcpClientForC> >(new TcpSessionWithSSL<TcpClientForC>(events));
+            return (TcpClientForC::Ptr *)new std::shared_ptr<TcpSessionWithSSL<TcpClientForC> >(new TcpSessionWithSSL<TcpClientForC>(events));
        case mk_type_ws:
            //此处你也可以修改WebSocketHeader::BINARY
-            return (TcpClientForC::Ptr *)new shared_ptr<WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, false> >(new WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, false>(events));
+            return (TcpClientForC::Ptr *)new std::shared_ptr<WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, false> >(new WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, false>(events));
        case mk_type_wss:
            //此处你也可以修改WebSocketHeader::BINARY
-            return (TcpClientForC::Ptr *)new shared_ptr<WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, true> >(new WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, true>(events));
+            return (TcpClientForC::Ptr *)new std::shared_ptr<WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, true> >(new WebSocketClient<TcpClientForC, WebSocketHeader::TEXT, true>(events));
        default:
            return nullptr;
    }
@@ -253,7 +255,7 @@ API_EXPORT void API_CALL mk_tcp_client_send(mk_tcp_client ctx, const char *data,
 API_EXPORT void API_CALL mk_tcp_client_send_safe(mk_tcp_client ctx, const char *data, int len){
    assert(ctx && data);
    TcpClientForC::Ptr *client = (TcpClientForC::Ptr *)ctx;
-    weak_ptr<TcpClient> weakClient = *client;
+    std::weak_ptr<TcpClient> weakClient = *client;
    auto buf = BufferRaw::create();
    buf->assign(data,len);
    (*client)->async([weakClient,buf](){

--- a/api/source/mk_tcp_private.h
+++ b/api/source/mk_tcp_private.h
@@ -14,17 +14,16 @@
 #include "mk_tcp.h"
 #include "Network/TcpClient.h"
 #include "Network/TcpSession.h"
-using namespace toolkit;
-class TcpClientForC : public TcpClient {
+class TcpClientForC : public toolkit::TcpClient {
 public:
    typedef std::shared_ptr<TcpClientForC> Ptr;
    TcpClientForC(mk_tcp_client_events *events) ;
    ~TcpClientForC() override ;
-    void onRecv(const Buffer::Ptr &pBuf) override;
+    void onRecv(const toolkit::Buffer::Ptr &pBuf) override;
-    void onErr(const SockException &ex) override;
+    void onErr(const toolkit::SockException &ex) override;
    void onManager() override;
-    void onConnect(const SockException &ex) override;
+    void onConnect(const toolkit::SockException &ex) override;
    void setClient(mk_tcp_client client);
    void *_user_data;
 private:
@@ -32,12 +31,12 @@ private:
    mk_tcp_client _client;
 };
-class TcpSessionForC : public TcpSession {
+class TcpSessionForC : public toolkit::TcpSession {
 public:
-    TcpSessionForC(const Socket::Ptr &pSock) ;
+    TcpSessionForC(const toolkit::Socket::Ptr &pSock) ;
    ~TcpSessionForC() override = default;
-    void onRecv(const Buffer::Ptr &buffer) override ;
+    void onRecv(const toolkit::Buffer::Ptr &buffer) override ;
-    void onError(const SockException &err) override;
+    void onError(const toolkit::SockException &err) override;
    void onManager() override;
    void *_user_data;
    uint16_t _local_port;

--- a/api/source/mk_thread.cpp
+++ b/api/source/mk_thread.cpp
@@ -91,7 +91,7 @@ private:
    on_mk_timer _cb = nullptr;
    void *_user_data = nullptr;
    recursive_mutex _mxt;
-    DelayTask::Ptr _task;
+    EventPoller::DelayTask::Ptr _task;
 };
 API_EXPORT mk_timer API_CALL mk_timer_create(mk_thread ctx,uint64_t delay_ms,on_mk_timer cb, void *user_data){

--- a/api/source/mk_util.cpp
+++ b/api/source/mk_util.cpp
@@ -8,10 +8,13 @@
 * may be found in the AUTHORS file in the root of the source tree.
 */
+#include <cstdarg>
+#include <cassert>
 #include "mk_util.h"
-#include <assert.h>
 #include "Util/util.h"
 #include "Util/logger.h"
 using namespace std;
 using namespace toolkit;

--- a/cmake/checks/atomic_check.cpp
+++ b/cmake/checks/atomic_check.cpp
+#include <atomic>
+static int test()
+{
+    std::atomic<long long> x;
+    return x;
+}
+int main()
+{
+    return test();
+}
\ No newline at end of file
--- a/player/AudioSRC.h
+++ b/player/AudioSRC.h
@@ -30,9 +30,6 @@ extern "C" {
 #include "SDLAudioDevice.h"
 #include "FFMpegDecoder.h"
-using namespace std;
-using namespace toolkit;
 class AudioSRCDelegate {
 public:
    virtual ~AudioSRCDelegate() {};
@@ -58,7 +55,7 @@ private:
    int _buf_size = 0;
    std::shared_ptr<char> _buf;
    AudioSRCDelegate *_delegate = nullptr;
-    BufferLikeString _target_buf;
+    toolkit::BufferLikeString _target_buf;
    SDL_AudioCVT _audio_cvt;
 };
@@ -79,8 +76,8 @@ private:
 private:
    int _sample_rate, _channel;
    SDL_AudioFormat _format;
-    mutex _mtx;
+    std::mutex _mtx;
-    BufferLikeString _buffer;
+    toolkit::BufferLikeString _buffer;
    SDLAudioDevice::Ptr _device;
 };

--- a/player/FFMpegDecoder.cpp
+++ b/player/FFMpegDecoder.cpp
@@ -12,6 +12,7 @@
 #define MAX_DELAY_SECOND 3
 using namespace std;
+using namespace toolkit;
 using namespace mediakit;
 static string ffmpeg_err(int errnum) {

--- a/player/FFMpegDecoder.h
+++ b/player/FFMpegDecoder.h
@@ -60,15 +60,15 @@ public:
    ~TaskManager();
 protected:
-    void startThread(const string &name);
+    void startThread(const std::string &name);
    void stopThread();
-    void addEncodeTask(function<void()> task);
+    void addEncodeTask(std::function<void()> task);
-    void addDecodeTask(bool key_frame, function<void()> task);
+    void addDecodeTask(bool key_frame, std::function<void()> task);
    bool isEnabled() const;
 private:
-    void onThreadRun(const string &name);
+    void onThreadRun(const std::string &name);
    void pushExit();
 private:
@@ -81,36 +81,36 @@ private:
 private:
    bool _decode_drop_start = false;
    bool _exit = false;
-    mutex _task_mtx;
+    std::mutex _task_mtx;
-    semaphore _sem;
+    toolkit::semaphore _sem;
-    List<function<void()> > _task;
+    toolkit::List<std::function<void()> > _task;
-    std::shared_ptr<thread> _thread;
+    std::shared_ptr<std::thread> _thread;
 };
 class FFmpegDecoder : private TaskManager {
 public:
    using Ptr = std::shared_ptr<FFmpegDecoder>;
-    using onDec = function<void(const FFmpegFrame::Ptr &)>;
+    using onDec = std::function<void(const FFmpegFrame::Ptr &)>;
-    FFmpegDecoder(const Track::Ptr &track);
+    FFmpegDecoder(const mediakit::Track::Ptr &track);
    ~FFmpegDecoder();
-    bool inputFrame(const Frame::Ptr &frame, bool may_async = true);
+    bool inputFrame(const mediakit::Frame::Ptr &frame, bool may_async = true);
    void setOnDecode(onDec cb);
    void flush();
    const AVCodecContext *getContext() const;
 private:
    void onDecode(const FFmpegFrame::Ptr &frame);
-    bool inputFrame_l(const Frame::Ptr &frame);
+    bool inputFrame_l(const mediakit::Frame::Ptr &frame);
    bool decodeFrame(const char *data, size_t size, uint32_t dts, uint32_t pts);
 private:
    bool _do_merger = false;
-    Ticker _ticker;
+    toolkit::Ticker _ticker;
    onDec _cb;
    std::shared_ptr<AVCodecContext> _context;
-    FrameMerger _merger{FrameMerger::h264_prefix};
+    mediakit::FrameMerger _merger { mediakit::FrameMerger::h264_prefix };
 };
 #endif /* FFMpegDecoder_H_ */

--- a/player/SDLAudioDevice.h
+++ b/player/SDLAudioDevice.h
@@ -21,7 +21,6 @@
 #define DEFAULT_CHANNEL 2
 #define DEFAULT_SAMPLES 1024
-using namespace std;
 class AudioSRC;
@@ -43,8 +42,8 @@ private:
 private:
    std::shared_ptr<char> _play_buf;
    SDL_AudioSpec _audio_config;
-    recursive_mutex _channel_mtx;
+    std::recursive_mutex _channel_mtx;
-    unordered_set<AudioSRC *> _channels;
+    std::unordered_set<AudioSRC *> _channels;
 };
 #endif /* SDLAUDIOMIXER_SDLAUDIODEVICE_H_ */
--- a/player/YuvDisplayer.h
+++ b/player/YuvDisplayer.h
@@ -25,12 +25,8 @@ extern "C" {
 #pragma comment(lib,"SDL2.lib")
 #endif //defined(_WIN32)
-using namespace toolkit;
-using namespace mediakit;
 #define REFRESH_EVENT   (SDL_USEREVENT + 1)
 class SDLDisplayerHelper
 {
 public:
@@ -44,7 +40,7 @@ public:
    template<typename FUN>
    void doTask(FUN &&f){
        {
-            lock_guard<mutex> lck(_mtxTask);
+            std::lock_guard<std::mutex> lck(_mtxTask);
            _taskList.emplace_back(f);
        }
        SDL_Event event;
@@ -61,8 +57,8 @@ public:
            switch (event.type){
                case REFRESH_EVENT:{
                    {
-                        lock_guard<mutex> lck(_mtxTask);
+                        std::lock_guard<std::mutex> lck(_mtxTask);
-                        if(_taskList.empty()){
+                        if (_taskList.empty()) {
                            //not reachable
                            continue;
                        }
@@ -102,17 +98,17 @@ public:
    using Ptr = std::shared_ptr<YuvDisplayer>;
    YuvDisplayer(void *hwnd = nullptr,const char *title = "untitled"){
-        static onceToken token([]() {
+        static toolkit::onceToken token([]() {
-            if(SDL_Init(SDL_INIT_VIDEO|SDL_INIT_AUDIO) == -1) {
+            if (SDL_Init(SDL_INIT_VIDEO|SDL_INIT_AUDIO) == -1) {
-                string err = "初始化SDL失败:";
+                std::string err = "初始化SDL失败:";
                err+= SDL_GetError();
                ErrorL << err;
                throw std::runtime_error(err);
            }
            SDL_LogSetAllPriority(SDL_LOG_PRIORITY_CRITICAL);
-            SDL_LogSetOutputFunction([](void *userdata, int category, SDL_LogPriority priority, const char *message){
+            SDL_LogSetOutputFunction([](void *userdata, int category, SDL_LogPriority priority, const char *message) {
                DebugL << category << " " <<  priority << message;
-            },nullptr);
+            }, nullptr);
            InfoL << "SDL_Init";
        }, []() {
            SDLDisplayerHelper::Destory();
@@ -194,7 +190,7 @@ public:
        return false;
    }
 private:
-    string _title;
+    std::string _title;
    SDL_Window *_win = nullptr;
    SDL_Renderer *_render = nullptr;
    SDL_Texture *_texture = nullptr;

--- a/player/test_player.cpp
+++ b/player/test_player.cpp
@@ -116,7 +116,7 @@ int main(int argc, char *argv[]) {
        WarnL << "play shutdown: " << ex.what();
    });
-    (*player)[kRtpType] = atoi(argv[2]);
+    (*player)[Client::kRtpType] = atoi(argv[2]);
    //不等待track ready再回调播放成功事件，这样可以加快秒开速度
    (*player)[Client::kWaitTrackReady] = false;
    player->play(argv[1]);

--- a/server/FFmpegSource.cpp
+++ b/server/FFmpegSource.cpp
@@ -16,6 +16,10 @@
 #include "Thread/WorkThreadPool.h"
 #include "Network/sockutil.h"
+using namespace std;
+using namespace toolkit;
+using namespace mediakit;
 namespace FFmpeg {
 #define FFmpeg_FIELD "ffmpeg."
 const string kBin = FFmpeg_FIELD"bin";

--- a/server/FFmpegSource.h
+++ b/server/FFmpegSource.h
@@ -19,12 +19,8 @@
 #include "Network/Socket.h"
 #include "Common/MediaSource.h"
-using namespace std;
-using namespace toolkit;
-using namespace mediakit;
 namespace FFmpeg {
-    extern const string kSnap;
+    extern const std::string kSnap;
 }
 class FFmpegSnap {
@@ -34,16 +30,16 @@ public:
    /// \param save_path 截图jpeg文件保存路径
    /// \param timeout_sec 生成截图超时时间(防止阻塞太久)
    /// \param cb 生成截图成功与否回调
-    static void makeSnap(const string &play_url, const string &save_path, float timeout_sec, const function<void(bool)> &cb);
+    static void makeSnap(const std::string &play_url, const std::string &save_path, float timeout_sec, const std::function<void(bool)> &cb);
 private:
    FFmpegSnap() = delete;
    ~FFmpegSnap() = delete;
 };
-class FFmpegSource : public std::enable_shared_from_this<FFmpegSource> , public MediaSourceEventInterceptor{
+class FFmpegSource : public std::enable_shared_from_this<FFmpegSource> , public mediakit::MediaSourceEventInterceptor{
 public:
-    typedef shared_ptr<FFmpegSource> Ptr;
+    using Ptr = std::shared_ptr<FFmpegSource>;
-    typedef function<void(const SockException &ex)> onPlay;
+    using onPlay = std::function<void(const toolkit::SockException &ex)>;
    FFmpegSource();
    ~FFmpegSource();
@@ -51,7 +47,7 @@ public:
    /**
     * 设置主动关闭回调
     */
-    void setOnClose(const function<void()> &cb);
+    void setOnClose(const std::function<void()> &cb);
    /**
     * 开始播放url
@@ -61,7 +57,7 @@ public:
     * @param timeout_ms 等待结果超时时间，单位毫秒
     * @param cb 成功与否回调
     */
-    void play(const string &ffmpeg_cmd_key, const string &src_url, const string &dst_url, int timeout_ms, const onPlay &cb);
+    void play(const std::string &ffmpeg_cmd_key, const std::string &src_url, const std::string &dst_url, int timeout_ms, const onPlay &cb);
    /**
     * 设置录制
@@ -71,32 +67,32 @@ public:
    void setupRecordFlag(bool enable_hls, bool enable_mp4);
 private:
-    void findAsync(int maxWaitMS ,const function<void(const MediaSource::Ptr &src)> &cb);
+    void findAsync(int maxWaitMS ,const std::function<void(const mediakit::MediaSource::Ptr &src)> &cb);
    void startTimer(int timeout_ms);
-    void onGetMediaSource(const MediaSource::Ptr &src);
+    void onGetMediaSource(const mediakit::MediaSource::Ptr &src);
    ///////MediaSourceEvent override///////
    // 关闭
-    bool close(MediaSource &sender,bool force) override;
+    bool close(mediakit::MediaSource &sender,bool force) override;
    // 获取媒体源类型
-    MediaOriginType getOriginType(MediaSource &sender) const override;
+    mediakit::MediaOriginType getOriginType(mediakit::MediaSource &sender) const override;
    //获取媒体源url或者文件路径
-    string getOriginUrl(MediaSource &sender) const override;
+    std::string getOriginUrl(mediakit::MediaSource &sender) const override;
    // 获取媒体源客户端相关信息
-    std::shared_ptr<SockInfo> getOriginSock(MediaSource &sender) const override;
+    std::shared_ptr<toolkit::SockInfo> getOriginSock(mediakit::MediaSource &sender) const override;
 private:
    bool _enable_hls = false;
    bool _enable_mp4 = false;
    Process _process;
-    Timer::Ptr _timer;
+    toolkit::Timer::Ptr _timer;
-    EventPoller::Ptr _poller;
+    toolkit::EventPoller::Ptr _poller;
-    MediaInfo _media_info;
+    mediakit::MediaInfo _media_info;
-    string _src_url;
+    std::string _src_url;
-    string _dst_url;
+    std::string _dst_url;
-    string _ffmpeg_cmd_key;
+    std::string _ffmpeg_cmd_key;
-    function<void()> _onClose;
+    std::function<void()> _onClose;
-    Ticker _replay_ticker;
+    toolkit::Ticker _replay_ticker;
 };

--- a/server/Process.cpp
+++ b/server/Process.cpp
@@ -28,6 +28,7 @@
 #include "Poller/EventPoller.h"
 #include "Process.h"
 using namespace toolkit;
+using namespace std;
 void Process::run(const string &cmd, const string &log_file_tmp) {
    kill(2000);

--- a/server/Process.h
+++ b/server/Process.h
@@ -19,13 +19,12 @@ typedef int pid_t;
 #include <fcntl.h>
 #include <string>
-using namespace std;
 class Process {
 public:
    Process();
    ~Process();
-    void run(const string &cmd,const string &log_file);
+    void run(const std::string &cmd,const std::string &log_file);
    void kill(int max_delay,bool force = false);
    bool wait(bool block = true);
    int exit_code();

--- a/server/System.cpp
+++ b/server/System.cpp
@@ -25,6 +25,7 @@
 #include "Util/NoticeCenter.h"
 #include "Util/uv_errno.h"
 using namespace toolkit;
+using namespace std;
 const int MAX_STACK_FRAMES = 128;
 #define BroadcastOnCrashDumpArgs int &sig,const vector<vector<string> > &stack

--- a/server/System.h
+++ b/server/System.h
@@ -12,11 +12,10 @@
 #define ZLMEDIAKIT_SYSTEM_H
 #include <string>
-using namespace std;
 class System {
 public:
-    static string execute(const string &cmd);
+    static std::string execute(const std::string &cmd);
    static void startDaemon();
    static void systemSetup();
 };

--- a/server/WebApi.cpp
+++ b/server/WebApi.cpp
@@ -48,7 +48,8 @@
 #include <tchar.h>
 #endif // _WIN32
+using namespace std;
+using namespace Json;
 using namespace toolkit;
 using namespace mediakit;
@@ -461,11 +462,11 @@ void addStreamProxy(const string &vhost, const string &app, const string &stream
    s_proxyMap[key] = player;
    //指定RTP over TCP(播放rtsp时有效)
-    (*player)[kRtpType] = rtp_type;
+    (*player)[Client::kRtpType] = rtp_type;
    if (timeout_sec > 0.1) {
        //播放握手超时时间
-        (*player)[kTimeoutMS] = timeout_sec * 1000;
+        (*player)[Client::kTimeoutMS] = timeout_sec * 1000;
    }
    //开始播放，如果播放失败或者播放中止，将会自动重试若干次，默认一直重试
@@ -839,11 +840,11 @@ void installWebApi() {
        s_proxyPusherMap[key] = pusher;
        //指定RTP over TCP(播放rtsp时有效)
-        (*pusher)[kRtpType] = rtp_type;
+        (*pusher)[Client::kRtpType] = rtp_type;
        if (timeout_sec > 0.1) {
            //推流握手超时时间
-            (*pusher)[kTimeoutMS] = timeout_sec * 1000;
+            (*pusher)[Client::kTimeoutMS] = timeout_sec * 1000;
        }
        //开始推流，如果推流失败或者推流中止，将会自动重试若干次，默认一直重试

--- a/server/WebApi.h
+++ b/server/WebApi.h
@@ -18,23 +18,18 @@
 #include "Network/Socket.h"
 #include "Http/HttpSession.h"
-using namespace std;
-using namespace Json;
-using namespace toolkit;
-using namespace mediakit;
 //配置文件路径
-extern string g_ini_file;
+extern std::string g_ini_file;
 namespace mediakit {
 ////////////RTSP服务器配置///////////
 namespace Rtsp {
-extern const string kPort;
+extern const std::string kPort;
 } //namespace Rtsp
 ////////////RTMP服务器配置///////////
 namespace Rtmp {
-extern const string kPort;
+extern const std::string kPort;
 } //namespace RTMP
 }  // namespace mediakit
@@ -79,25 +74,25 @@ public:
    ~SuccessException() = default;
 };
-using ApiArgsType = map<string, string, StrCaseCompare>;
+using ApiArgsType = std::map<std::string, std::string, mediakit::StrCaseCompare>;
 template<typename Args, typename First>
-string getValue(Args &args, const First &first) {
+std::string getValue(Args &args, const First &first) {
    return args[first];
 }
 template<typename First>
-string getValue(Json::Value &args, const First &first) {
+std::string getValue(Json::Value &args, const First &first) {
    return args[first].asString();
 }
 template<typename First>
-string getValue(string &args, const First &first) {
+std::string getValue(std::string &args, const First &first) {
    return "";
 }
 template<typename First>
-string getValue(const Parser &parser, const First &first) {
+std::string getValue(const mediakit::Parser &parser, const First &first) {
    auto ret = parser.getUrlArgs()[first];
    if (!ret.empty()) {
        return ret;
@@ -106,12 +101,12 @@ string getValue(const Parser &parser, const First &first) {
 }
 template<typename First>
-string getValue(Parser &parser, const First &first) {
+std::string getValue(mediakit::Parser &parser, const First &first) {
-    return getValue((const Parser &) parser, first);
+    return getValue((const mediakit::Parser &) parser, first);
 }
 template<typename Args, typename First>
-string getValue(const Parser &parser, Args &args, const First &first) {
+std::string getValue(const mediakit::Parser &parser, Args &args, const First &first) {
    auto ret = getValue(args, first);
    if (!ret.empty()) {
        return ret;
@@ -122,24 +117,24 @@ string getValue(const Parser &parser, Args &args, const First &first) {
 template<typename Args>
 class HttpAllArgs {
 public:
-    HttpAllArgs(const Parser &parser, Args &args) {
+    HttpAllArgs(const mediakit::Parser &parser, Args &args) {
        _get_args = [&args]() {
            return (void *) &args;
        };
-        _get_parser = [&parser]() -> const Parser & {
+        _get_parser = [&parser]() -> const mediakit::Parser & {
            return parser;
        };
-        _get_value = [](HttpAllArgs &that, const string &key) {
+        _get_value = [](HttpAllArgs &that, const std::string &key) {
            return getValue(that.getParser(), that.getArgs(), key);
        };
        _clone = [&](HttpAllArgs &that) {
            that._get_args = [args]() {
                return (void *) &args;
            };
-            that._get_parser = [parser]() -> const Parser & {
+            that._get_parser = [parser]() -> const mediakit::Parser & {
                return parser;
            };
-            that._get_value = [](HttpAllArgs &that, const string &key) {
+            that._get_value = [](HttpAllArgs &that, const std::string &key) {
                return getValue(that.getParser(), that.getArgs(), key);
            };
            that._cache_able = true;
@@ -160,11 +155,11 @@ public:
    ~HttpAllArgs() = default;
    template<typename Key>
-    variant operator[](const Key &key) const {
+    toolkit::variant operator[](const Key &key) const {
-        return (variant)_get_value(*(HttpAllArgs*)this, key);
+        return (toolkit::variant)_get_value(*(HttpAllArgs*)this, key);
    }
-    const Parser &getParser() const {
+    const mediakit::Parser &getParser() const {
        return _get_parser();
    }
@@ -178,34 +173,34 @@ public:
 private:
    bool _cache_able = false;
-    function<void *() > _get_args;
+    std::function<void *() > _get_args;
-    function<const Parser &() > _get_parser;
+    std::function<const mediakit::Parser &() > _get_parser;
-    function<string(HttpAllArgs &that, const string &key)> _get_value;
+    std::function<std::string(HttpAllArgs &that, const std::string &key)> _get_value;
-    function<void(HttpAllArgs &that) > _clone;
+    std::function<void(HttpAllArgs &that) > _clone;
 };
-#define API_ARGS_MAP SockInfo &sender, HttpSession::KeyValue &headerOut, const HttpAllArgs<ApiArgsType> &allArgs, Json::Value &val
+#define API_ARGS_MAP toolkit::SockInfo &sender, mediakit::HttpSession::KeyValue &headerOut, const HttpAllArgs<ApiArgsType> &allArgs, Json::Value &val
-#define API_ARGS_MAP_ASYNC API_ARGS_MAP, const HttpSession::HttpResponseInvoker &invoker
+#define API_ARGS_MAP_ASYNC API_ARGS_MAP, const mediakit::HttpSession::HttpResponseInvoker &invoker
-#define API_ARGS_JSON SockInfo &sender, HttpSession::KeyValue &headerOut, const HttpAllArgs<Json::Value> &allArgs, Json::Value &val
+#define API_ARGS_JSON toolkit::SockInfo &sender, mediakit::HttpSession::KeyValue &headerOut, const HttpAllArgs<Json::Value> &allArgs, Json::Value &val
-#define API_ARGS_JSON_ASYNC API_ARGS_JSON, const HttpSession::HttpResponseInvoker &invoker
+#define API_ARGS_JSON_ASYNC API_ARGS_JSON, const mediakit::HttpSession::HttpResponseInvoker &invoker
-#define API_ARGS_STRING SockInfo &sender, HttpSession::KeyValue &headerOut, const HttpAllArgs<string> &allArgs, Json::Value &val
+#define API_ARGS_STRING toolkit::SockInfo &sender, mediakit::HttpSession::KeyValue &headerOut, const HttpAllArgs<std::string> &allArgs, Json::Value &val
-#define API_ARGS_STRING_ASYNC API_ARGS_STRING, const HttpSession::HttpResponseInvoker &invoker
+#define API_ARGS_STRING_ASYNC API_ARGS_STRING, const mediakit::HttpSession::HttpResponseInvoker &invoker
 #define API_ARGS_VALUE sender, headerOut, allArgs, val
 //注册http请求参数是map<string, variant, StrCaseCompare>类型的http api
-void api_regist(const string &api_path, const function<void(API_ARGS_MAP)> &func);
+void api_regist(const std::string &api_path, const std::function<void(API_ARGS_MAP)> &func);
 //注册http请求参数是map<string, variant, StrCaseCompare>类型,但是可以异步回复的的http api
-void api_regist(const string &api_path, const function<void(API_ARGS_MAP_ASYNC)> &func);
+void api_regist(const std::string &api_path, const std::function<void(API_ARGS_MAP_ASYNC)> &func);
 //注册http请求参数是Json::Value类型的http api(可以支持多级嵌套的json参数对象)
-void api_regist(const string &api_path, const function<void(API_ARGS_JSON)> &func);
+void api_regist(const std::string &api_path, const std::function<void(API_ARGS_JSON)> &func);
 //注册http请求参数是Json::Value类型，但是可以异步回复的的http api
-void api_regist(const string &api_path, const function<void(API_ARGS_JSON_ASYNC)> &func);
+void api_regist(const std::string &api_path, const std::function<void(API_ARGS_JSON_ASYNC)> &func);
 //注册http请求参数是http原始请求信息的http api
-void api_regist(const string &api_path, const function<void(API_ARGS_STRING)> &func);
+void api_regist(const std::string &api_path, const std::function<void(API_ARGS_STRING)> &func);
 //注册http请求参数是http原始请求信息的异步回复的http api
-void api_regist(const string &api_path, const function<void(API_ARGS_STRING_ASYNC)> &func);
+void api_regist(const std::string &api_path, const std::function<void(API_ARGS_STRING_ASYNC)> &func);
 template<typename Args, typename First>
 bool checkArgs(Args &args, const First &first) {
@@ -234,9 +229,9 @@ bool checkArgs(Args &args, const First &first, const KeyTypes &...keys) {
 void installWebApi();
 void unInstallWebApi();
-Value makeMediaSourceJson(MediaSource &media);
+Json::Value makeMediaSourceJson(mediakit::MediaSource &media);
-void getStatisticJson(const function<void(Value &val)> &cb);
+void getStatisticJson(const std::function<void(Json::Value &val)> &cb);
-void addStreamProxy(const string &vhost, const string &app, const string &stream, const string &url, int retry_count,
+void addStreamProxy(const std::string &vhost, const std::string &app, const std::string &stream, const std::string &url, int retry_count,
                    bool enable_hls, bool enable_mp4, int rtp_type, float timeout_sec,
-                    const function<void(const SockException &ex, const string &key)> &cb);
+                    const std::function<void(const toolkit::SockException &ex, const std::string &key)> &cb);
 #endif //ZLMEDIAKIT_WEBAPI_H
--- a/server/WebHook.cpp
+++ b/server/WebHook.cpp
@@ -21,6 +21,8 @@
 #include "WebHook.h"
 #include "WebApi.h"
+using namespace std;
+using namespace Json;
 using namespace toolkit;
 using namespace mediakit;

--- a/server/WebHook.h
+++ b/server/WebHook.h
@@ -14,21 +14,19 @@
 #include <string>
 #include <functional>
 #include "jsoncpp/json.h"
-using namespace std;
-using namespace Json;
 //支持json或urlencoded方式传输参数
 #define JSON_ARGS
 #ifdef JSON_ARGS
-typedef Value ArgsType;
+typedef Json::Value ArgsType;
 #else
-typedef HttpArgs ArgsType;
+typedef mediakit::HttpArgs ArgsType;
 #endif
 namespace Hook {
 //web hook回复最大超时时间
-extern const string kTimeoutSec;
+extern const std::string kTimeoutSec;
 }//namespace Hook
 void installWebHook();
@@ -39,5 +37,5 @@ void unInstallWebHook();
 * @param body 请求body
 * @param func 回调
 */
-void do_http_hook(const string &url, const ArgsType &body, const function<void(const Value &, const string &)> &func = nullptr);
+void do_http_hook(const std::string &url, const ArgsType &body, const std::function<void(const Json::Value &, const std::string &)> &func = nullptr);
 #endif //ZLMEDIAKIT_WEBHOOK_H
--- a/src/Common/Device.cpp
+++ b/src/Common/Device.cpp
@@ -24,6 +24,7 @@
 #include "Codec/H264Encoder.h"
 #endif //ENABLE_X264
 using namespace toolkit;
+using namespace std;
 namespace mediakit {

--- a/src/Common/Device.h
+++ b/src/Common/Device.h
@@ -17,8 +17,6 @@
 #include "Util/util.h"
 #include "Util/TimeTicker.h"
 #include "Common/MultiMediaSourceMuxer.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit {
@@ -48,7 +46,7 @@ class DevChannel  : public MultiMediaSourceMuxer{
 public:
    typedef std::shared_ptr<DevChannel> Ptr;
    //fDuration<=0为直播，否则为点播
-    DevChannel(const string &vhost, const string &app, const string &stream_id,
+    DevChannel(const std::string &vhost, const std::string &app, const std::string &stream_id,
               float duration = 0, bool enable_hls = true, bool enable_mp4 = false);
    ~DevChannel() override ;
@@ -126,7 +124,7 @@ private:
    std::shared_ptr<AACEncoder> _pAacEnc;
    std::shared_ptr<VideoInfo> _video;
    std::shared_ptr<AudioInfo> _audio;
-    SmoothTicker _aTicker[2];
+    toolkit::SmoothTicker _aTicker[2];
 };
 } /* namespace mediakit */

--- a/src/Common/MediaSink.cpp
+++ b/src/Common/MediaSink.cpp
@@ -11,6 +11,8 @@
 #include "MediaSink.h"
 #include "Extension/AAC.h"
+using namespace std;
 namespace mediakit{
 bool MediaSink::addTrack(const Track::Ptr &track_in) {

--- a/src/Common/MediaSink.h
+++ b/src/Common/MediaSink.h
@@ -17,9 +17,6 @@
 #include "Extension/Frame.h"
 #include "Extension/Track.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit{
 class TrackListener {
@@ -106,7 +103,7 @@ public:
     * 获取所有Track
     * @param trackReady 是否获取已经准备好的Track
     */
-    vector<Track::Ptr> getTracks(bool trackReady = true) const override;
+    std::vector<Track::Ptr> getTracks(bool trackReady = true) const override;
    /**
     * 返回是否所有track已经准备完成
@@ -154,10 +151,10 @@ private:
 private:
    bool _all_track_ready = false;
    size_t _max_track_size = 2;
-    unordered_map<int, pair<Track::Ptr, bool/*got frame*/> > _track_map;
+    std::unordered_map<int, std::pair<Track::Ptr, bool/*got frame*/> > _track_map;
-    unordered_map<int, List<Frame::Ptr> > _frame_unread;
+    std::unordered_map<int, toolkit::List<Frame::Ptr> > _frame_unread;
-    unordered_map<int, function<void()> > _track_ready_callback;
+    std::unordered_map<int, std::function<void()> > _track_ready_callback;
-    Ticker _ticker;
+    toolkit::Ticker _ticker;
    MuteAudioMaker::Ptr _mute_audio_maker;
 };

--- a/src/Common/MediaSource.cpp
+++ b/src/Common/MediaSource.cpp
@@ -13,6 +13,8 @@
 #include "Util/util.h"
 #include "Network/sockutil.h"
 #include "Network/TcpSession.h"
+using namespace std;
 using namespace toolkit;
 namespace toolkit {
@@ -91,7 +93,8 @@ std::shared_ptr<void> MediaSource::getOwnership() {
        return nullptr;
    }
    weak_ptr<MediaSource> weak_self = shared_from_this();
-    return std::shared_ptr<void>(this, [weak_self](void *ptr) {
+    //确保返回的Ownership智能指针不为空，0x01无实际意义
+    return std::shared_ptr<void>((void *) 0x01, [weak_self](void *ptr) {
        auto strong_self = weak_self.lock();
        if (strong_self) {
            strong_self->_owned.clear();
@@ -207,7 +210,7 @@ bool MediaSource::close(bool force) {
    if(!listener){
        return false;
    }
-    return listener->close(*this,force);
+    return listener->close(*this,force) && unregist();
 }
 void MediaSource::onReaderChanged(int size) {

--- a/src/Common/MediaSource.h
+++ b/src/Common/MediaSource.h
--- a/src/Common/MultiMediaSourceMuxer.cpp
+++ b/src/Common/MultiMediaSourceMuxer.cpp
@@ -12,6 +12,9 @@
 #include "Common/config.h"
 #include "MultiMediaSourceMuxer.h"
+using namespace std;
+using namespace toolkit;
 namespace toolkit {
    StatisticImp(mediakit::MultiMediaSourceMuxer);
 }

--- a/src/Common/MultiMediaSourceMuxer.h
+++ b/src/Common/MultiMediaSourceMuxer.h
@@ -35,7 +35,7 @@ public:
    };
    ~MultiMediaSourceMuxer() override = default;
-    MultiMediaSourceMuxer(const string &vhost, const string &app, const string &stream, float dur_sec = 0.0,
+    MultiMediaSourceMuxer(const std::string &vhost, const std::string &app, const std::string &stream, float dur_sec = 0.0,
                          bool enable_rtsp = true, bool enable_rtmp = true, bool enable_hls = true, bool enable_mp4 = false);
    /**
@@ -87,7 +87,7 @@ public:
     * @param custom_path 开启录制时，指定自定义路径
     * @return 是否设置成功
     */
-    bool setupRecord(MediaSource &sender, Recorder::type type, bool start, const string &custom_path, size_t max_second) override;
+    bool setupRecord(MediaSource &sender, Recorder::type type, bool start, const std::string &custom_path, size_t max_second) override;
    /**
     * 获取录制状态
@@ -104,20 +104,20 @@ public:
     * @param is_udp 是否为udp
     * @param cb 启动成功或失败回调
     */
-    void startSendRtp(MediaSource &sender, const string &dst_url, uint16_t dst_port, const string &ssrc, bool is_udp, uint16_t src_port, const function<void(uint16_t local_port, const SockException &ex)> &cb) override;
+    void startSendRtp(MediaSource &sender, const std::string &dst_url, uint16_t dst_port, const std::string &ssrc, bool is_udp, uint16_t src_port, const std::function<void(uint16_t local_port, const toolkit::SockException &ex)> &cb) override;
    /**
     * 停止ps-rtp发送
     * @return 是否成功
     */
-    bool stopSendRtp(MediaSource &sender, const string &ssrc) override;
+    bool stopSendRtp(MediaSource &sender, const std::string &ssrc) override;
    /**
     * 获取所有Track
     * @param trackReady 是否筛选过滤未就绪的track
     * @return 所有Track
     */
-    vector<Track::Ptr> getMediaTracks(MediaSource &sender, bool trackReady = true) const override;
+    std::vector<Track::Ptr> getMediaTracks(MediaSource &sender, bool trackReady = true) const override;
 protected:
    /////////////////////////////////MediaSink override/////////////////////////////////
@@ -142,13 +142,13 @@ protected:
 private:
    bool _is_enable = false;
-    Ticker _last_check;
+    toolkit::Ticker _last_check;
    Stamp _stamp[2];
    std::weak_ptr<Listener> _track_listener;
-    function<string()> _get_origin_url;
+    std::function<std::string()> _get_origin_url;
 #if defined(ENABLE_RTPPROXY)
-    mutex _rtp_sender_mtx;
+    std::mutex _rtp_sender_mtx;
-	unordered_map<string, RtpSender::Ptr> _rtp_sender;
+    std::unordered_map<std::string, RtpSender::Ptr> _rtp_sender;
 #endif //ENABLE_RTPPROXY
 #if defined(ENABLE_MP4)
@@ -161,7 +161,7 @@ private:
    HlsRecorder::Ptr _hls;
    //对象个数统计
-    ObjectStatistic<MultiMediaSourceMuxer> _statistic;
+    toolkit::ObjectStatistic<MultiMediaSourceMuxer> _statistic;
 };
 }//namespace mediakit

--- a/src/Common/Parser.cpp
+++ b/src/Common/Parser.cpp
@@ -10,6 +10,9 @@
 #include "Parser.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 string FindField(const char* buf, const char* start, const char *end ,size_t bufSize) {

--- a/src/Common/Parser.h
+++ b/src/Common/Parser.h
@@ -15,26 +15,23 @@
 #include <string>
 #include "Util/util.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit {
-string FindField(const char *buf, const char *start, const char *end, size_t bufSize = 0);
+std::string FindField(const char *buf, const char *start, const char *end, size_t bufSize = 0);
 struct StrCaseCompare {
-    bool operator()(const string &__x, const string &__y) const {
+    bool operator()(const std::string &__x, const std::string &__y) const {
        return strcasecmp(__x.data(), __y.data()) < 0;
    }
 };
-class StrCaseMap : public multimap<string, string, StrCaseCompare> {
+class StrCaseMap : public std::multimap<std::string, std::string, StrCaseCompare> {
 public:
-    using Super = multimap<string, string, StrCaseCompare>;
+    using Super = multimap<std::string, std::string, StrCaseCompare>;
    StrCaseMap() = default;
    ~StrCaseMap() = default;
-    string &operator[](const string &k) {
+    std::string &operator[](const std::string &k) {
        auto it = find(k);
        if (it == end()) {
            it = Super::emplace(k, "");
@@ -43,7 +40,7 @@ public:
    }
    template<typename V>
-    void emplace(const string &k, V &&v) {
+    void emplace(const std::string &k, V &&v) {
        auto it = find(k);
        if (it != end()) {
            return;
@@ -52,7 +49,7 @@ public:
    }
    template<typename V>
-    void emplace_force(const string k, V &&v) {
+    void emplace_force(const std::string k, V &&v) {
        Super::emplace(k, std::forward<V>(v));
    }
 };
@@ -67,34 +64,34 @@ public:
    void Parse(const char *buf);
    //获取命令字
-    const string &Method() const;
+    const std::string &Method() const;
    //获取中间url，不包含?后面的参数
-    const string &Url() const;
+    const std::string &Url() const;
    //获取中间url，包含?后面的参数
-    string FullUrl() const;
+    std::string FullUrl() const;
    //获取命令协议名
-    const string &Tail() const;
+    const std::string &Tail() const;
    //根据header key名，获取请求header value值
-    const string &operator[](const char *name) const;
+    const std::string &operator[](const char *name) const;
    //获取http body或sdp
-    const string &Content() const;
+    const std::string &Content() const;
    //清空，为了重用
    void Clear();
    //获取?后面的参数
-    const string &Params() const;
+    const std::string &Params() const;
    //重新设置url
-    void setUrl(string url);
+    void setUrl(std::string url);
    //重新设置content
-    void setContent(string content);
+    void setContent(std::string content);
    //获取header列表
    StrCaseMap &getHeader() const;
@@ -103,15 +100,15 @@ public:
    StrCaseMap &getUrlArgs() const;
    //解析?后面的参数
-    static StrCaseMap parseArgs(const string &str, const char *pair_delim = "&", const char *key_delim = "=");
+    static StrCaseMap parseArgs(const std::string &str, const char *pair_delim = "&", const char *key_delim = "=");
 private:
-    string _strMethod;
+    std::string _strMethod;
-    string _strUrl;
+    std::string _strUrl;
-    string _strTail;
+    std::string _strTail;
-    string _strContent;
+    std::string _strContent;
-    string _strNull;
+    std::string _strNull;
-    string _params;
+    std::string _params;
    mutable StrCaseMap _mapHeaders;
    mutable StrCaseMap _mapUrlArgs;
 };

--- a/src/Common/Stamp.cpp
+++ b/src/Common/Stamp.cpp
@@ -16,6 +16,8 @@
 #define MAX_CTS 500
 #define ABS(x) ((x) > 0 ? (x) : (-x))
+using namespace toolkit;
 namespace mediakit {
 int64_t DeltaStamp::deltaStamp(int64_t stamp) {

--- a/src/Common/Stamp.h
+++ b/src/Common/Stamp.h
@@ -14,7 +14,6 @@
 #include <set>
 #include <cstdint>
 #include "Util/TimeTicker.h"
-using namespace toolkit;
 namespace mediakit {
@@ -87,7 +86,7 @@ private:
    int64_t _last_dts_in = 0;
    int64_t _last_dts_out = 0;
    int64_t _last_pts_out = 0;
-    SmoothTicker _ticker;
+    toolkit::SmoothTicker _ticker;
    bool _playback = false;
    Stamp *_sync_master = nullptr;
 };
@@ -111,7 +110,7 @@ private:
    size_t _frames_since_last_max_pts = 0;
    size_t _sorter_max_size = 0;
    size_t _count_sorter_max_size = 0;
-    set<uint32_t> _pts_sorter;
+    std::set<uint32_t> _pts_sorter;
 };
 class NtpStamp {

--- a/src/Common/config.cpp
+++ b/src/Common/config.cpp
@@ -15,6 +15,7 @@
 #include "Util/onceToken.h"
 #include "Util/NoticeCenter.h"
+using namespace std;
 using namespace toolkit;
 namespace mediakit {

--- a/src/Common/config.h
+++ b/src/Common/config.h
--- a/src/Extension/AAC.cpp
+++ b/src/Extension/AAC.cpp
@@ -13,6 +13,9 @@
 #include "mpeg4-aac.h"
 #endif
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 #ifndef ENABLE_MP4

--- a/src/Extension/AAC.h
+++ b/src/Extension/AAC.h
@@ -17,10 +17,10 @@
 namespace mediakit{
-string makeAacConfig(const uint8_t *hex, size_t length);
+std::string makeAacConfig(const uint8_t *hex, size_t length);
 int getAacFrameLength(const uint8_t *hex, size_t length);
-int dumpAacConfig(const string &config, size_t length, uint8_t *out, size_t out_size);
+int dumpAacConfig(const std::string &config, size_t length, uint8_t *out, size_t out_size);
-bool parseAacConfig(const string &config, int &samplerate, int &channels);
+bool parseAacConfig(const std::string &config, int &samplerate, int &channels);
 /**
 * aac音频通道
@@ -39,12 +39,12 @@ public:
     * 构造aac类型的媒体
     * @param aac_cfg aac配置信息
     */
-    AACTrack(const string &aac_cfg);
+    AACTrack(const std::string &aac_cfg);
    /**
     * 获取aac 配置信息
     */
-    const string &getAacCfg() const;
+    const std::string &getAacCfg() const;
    bool ready() override;
    CodecId getCodecId() const override;
@@ -60,7 +60,7 @@ private:
    bool inputFrame_l(const Frame::Ptr &frame);
 private:
-    string _cfg;
+    std::string _cfg;
    int _channel = 0;
    int _sampleRate = 0;
    int _sampleBit = 16;

--- a/src/Extension/AACRtmp.cpp
+++ b/src/Extension/AACRtmp.cpp
@@ -11,7 +11,10 @@
 #include "AACRtmp.h"
 #include "Rtmp/Rtmp.h"
-namespace mediakit{
+using namespace std;
+using namespace toolkit;
+namespace mediakit {
 static string getAacCfg(const RtmpPacket &thiz) {
    string ret;

--- a/src/Extension/AACRtmp.h
+++ b/src/Extension/AACRtmp.h
@@ -40,7 +40,7 @@ private:
    void onGetAAC(const char *data, size_t len, uint32_t stamp);
 private:
-    string _aac_cfg;
+    std::string _aac_cfg;
 };
@@ -77,7 +77,7 @@ private:
 private:
    uint8_t _audio_flv_flags;
    AACTrack::Ptr _track;
-    string _aac_cfg;
+    std::string _aac_cfg;
 };
 }//namespace mediakit

--- a/src/Extension/AACRtp.cpp
+++ b/src/Extension/AACRtp.cpp
@@ -60,7 +60,7 @@ void AACRtpEncoder::makeAACRtp(const void *data, size_t len, bool mark, uint32_t
 /////////////////////////////////////////////////////////////////////////////////////
 AACRtpDecoder::AACRtpDecoder(const Track::Ptr &track) {
-    auto aacTrack = dynamic_pointer_cast<AACTrack>(track);
+    auto aacTrack = std::dynamic_pointer_cast<AACTrack>(track);
    if (!aacTrack || !aacTrack->ready()) {
        WarnL << "该aac track无效!";
    } else {

--- a/src/Extension/AACRtp.h
+++ b/src/Extension/AACRtp.h
@@ -44,7 +44,7 @@ private:
 private:
    uint32_t _last_dts = 0;
-    string _aac_cfg;
+    std::string _aac_cfg;
    FrameImp::Ptr _frame;
 };

--- a/src/Extension/CommonRtp.cpp
+++ b/src/Extension/CommonRtp.cpp
@@ -10,6 +10,8 @@
 #include "CommonRtp.h"
+using namespace mediakit;
 CommonRtpDecoder::CommonRtpDecoder(CodecId codec, size_t max_frame_size ){
    _codec = codec;
    _max_frame_size = max_frame_size;

--- a/src/Extension/Factory.cpp
+++ b/src/Extension/Factory.cpp
@@ -24,6 +24,8 @@
 #include "L16.h"
 #include "Common/Parser.h"
+using namespace std;
 namespace mediakit{
 Track::Ptr Factory::getTrackBySdp(const SdpTrack::Ptr &track) {

--- a/src/Extension/Factory.h
+++ b/src/Extension/Factory.h
@@ -17,9 +17,6 @@
 #include "Rtsp/RtpCodec.h"
 #include "Rtmp/RtmpCodec.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit{
 class Factory {

--- a/src/Extension/Frame.h
+++ b/src/Extension/Frame.h
@@ -16,9 +16,6 @@
 #include "Util/RingBuffer.h"
 #include "Network/Socket.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit{
 typedef enum {
@@ -53,7 +50,7 @@ typedef enum {
 /**
 * 字符串转媒体类型转
 */
-TrackType getTrackType(const string &str);
+TrackType getTrackType(const std::string &str);
 /**
 * 媒体类型转字符串
@@ -65,7 +62,7 @@ const char* getTrackString(TrackType type);
 * @param str
 * @return
 */
-CodecId getCodecId(const string &str);
+CodecId getCodecId(const std::string &str);
 /**
 * 获取编码器名称
@@ -106,7 +103,7 @@ public:
 /**
 * 帧类型的抽象接口
 */
-class Frame : public Buffer, public CodecInfo {
+class Frame : public toolkit::Buffer, public CodecInfo {
 public:
    typedef std::shared_ptr<Frame> Ptr;
    virtual ~Frame(){}
@@ -171,7 +168,7 @@ public:
 private:
    //对象个数统计
-    ObjectStatistic<Frame> _statistic;
+    toolkit::ObjectStatistic<Frame> _statistic;
 };
 class FrameImp : public Frame {
@@ -233,14 +230,14 @@ public:
    uint32_t _dts = 0;
    uint32_t _pts = 0;
    size_t _prefix_size = 0;
-    BufferLikeString _buffer;
+    toolkit::BufferLikeString _buffer;
 private:
    //对象个数统计
-    ObjectStatistic<FrameImp> _statistic;
+    toolkit::ObjectStatistic<FrameImp> _statistic;
 protected:
-    friend class ResourcePool_l<FrameImp>;
+    friend class toolkit::ResourcePool_l<FrameImp>;
    FrameImp() = default;
 };
@@ -323,7 +320,7 @@ public:
     */
    void addDelegate(const FrameWriterInterface::Ptr &delegate){
        //_delegates_write可能多线程同时操作
-        lock_guard<mutex> lck(_mtx);
+        std::lock_guard<std::mutex> lck(_mtx);
        _delegates_write.emplace(delegate.get(),delegate);
        _need_update = true;
    }
@@ -333,7 +330,7 @@ public:
     */
    void delDelegate(FrameWriterInterface *ptr){
        //_delegates_write可能多线程同时操作
-        lock_guard<mutex> lck(_mtx);
+        std::lock_guard<std::mutex> lck(_mtx);
        _delegates_write.erase(ptr);
        _need_update = true;
    }
@@ -344,7 +341,7 @@ public:
    bool inputFrame(const Frame::Ptr &frame) override{
        if(_need_update){
            //发现代理列表发生变化了，这里同步一次
-            lock_guard<mutex> lck(_mtx);
+            std::lock_guard<std::mutex> lck(_mtx);
            _delegates_read = _delegates_write;
            _need_update = false;
        }
@@ -366,9 +363,9 @@ public:
        return _delegates_write.size();
    }
 private:
-    mutex _mtx;
+    std::mutex _mtx;
-    map<void *,FrameWriterInterface::Ptr>  _delegates_read;
+    std::map<void *,FrameWriterInterface::Ptr>  _delegates_read;
-    map<void *,FrameWriterInterface::Ptr>  _delegates_write;
+    std::map<void *,FrameWriterInterface::Ptr>  _delegates_write;
    bool _need_update = false;
 };
@@ -463,7 +460,7 @@ public:
     * @param prefix 帧前缀长度
     * @param offset buffer有效数据偏移量
     */
-    FrameWrapper(const Buffer::Ptr &buf, uint32_t dts, uint32_t pts, size_t prefix, size_t offset) : Parent(buf->data() + offset, buf->size() - offset, dts, pts, prefix){
+    FrameWrapper(const toolkit::Buffer::Ptr &buf, uint32_t dts, uint32_t pts, size_t prefix, size_t offset) : Parent(buf->data() + offset, buf->size() - offset, dts, pts, prefix){
        _buf = buf;
    }
@@ -476,7 +473,7 @@ public:
     * @param offset buffer有效数据偏移量
     * @param codec 帧类型
     */
-    FrameWrapper(const Buffer::Ptr &buf, uint32_t dts, uint32_t pts, size_t prefix, size_t offset, CodecId codec) : Parent(codec, buf->data() + offset, buf->size() - offset, dts, pts, prefix){
+    FrameWrapper(const toolkit::Buffer::Ptr &buf, uint32_t dts, uint32_t pts, size_t prefix, size_t offset, CodecId codec) : Parent(codec, buf->data() + offset, buf->size() - offset, dts, pts, prefix){
        _buf = buf;
    }
@@ -488,7 +485,7 @@ public:
    }
 private:
-    Buffer::Ptr _buf;
+    toolkit::Buffer::Ptr _buf;
 };
 /**
@@ -496,7 +493,7 @@ private:
 */
 class FrameMerger {
 public:
-    using onOutput = function<void(uint32_t dts, uint32_t pts, const Buffer::Ptr &buffer, bool have_key_frame)>;
+    using onOutput = std::function<void(uint32_t dts, uint32_t pts, const toolkit::Buffer::Ptr &buffer, bool have_key_frame)>;
    using Ptr = std::shared_ptr<FrameMerger>;
    enum {
        none = 0,
@@ -508,16 +505,16 @@ public:
    ~FrameMerger() = default;
    void clear();
-    bool inputFrame(const Frame::Ptr &frame, const onOutput &cb, BufferLikeString *buffer = nullptr);
+    bool inputFrame(const Frame::Ptr &frame, const onOutput &cb, toolkit::BufferLikeString *buffer = nullptr);
 private:
    bool willFlush(const Frame::Ptr &frame) const;
-    void doMerge(BufferLikeString &buffer, const Frame::Ptr &frame) const;
+    void doMerge(toolkit::BufferLikeString &buffer, const Frame::Ptr &frame) const;
 private:
    int _type;
    bool _have_decode_able_frame = false;
-    List<Frame::Ptr> _frame_cache;
+    toolkit::List<Frame::Ptr> _frame_cache;
 };
 }//namespace mediakit

--- a/src/Extension/G711.cpp
+++ b/src/Extension/G711.cpp
@@ -10,6 +10,9 @@
 #include "G711.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 /**

--- a/src/Extension/H264.cpp
+++ b/src/Extension/H264.cpp
@@ -12,6 +12,7 @@
 #include "SPSParser.h"
 #include "Util/logger.h"
 using namespace toolkit;
+using namespace std;
 namespace mediakit{

--- a/src/Extension/H264.h
+++ b/src/Extension/H264.h
@@ -14,12 +14,12 @@
 #include "Frame.h"
 #include "Track.h"
 #include "Util/base64.h"
 #define H264_TYPE(v) ((uint8_t)(v) & 0x1F)
-using namespace toolkit;
 namespace mediakit{
-bool getAVCInfo(const string &strSps,int &iVideoWidth, int &iVideoHeight, float &iVideoFps);
+bool getAVCInfo(const std::string &strSps,int &iVideoWidth, int &iVideoHeight, float &iVideoFps);
 void splitH264(const char *ptr, size_t len, size_t prefix, const std::function<void(const char *, size_t, size_t)> &cb);
 size_t prefixSize(const char *ptr, size_t len);
@@ -27,7 +27,7 @@ template<typename Parent>
 class H264FrameHelper : public Parent{
 public:
    friend class FrameImp;
-    friend class ResourcePool_l<H264FrameHelper>;
+    friend class toolkit::ResourcePool_l<H264FrameHelper>;
    using Ptr = std::shared_ptr<H264FrameHelper>;
    enum {
@@ -108,7 +108,7 @@ public:
     * @param sps_prefix_len 264头长度，可以为3个或4个字节，一般为0x00 00 00 01
     * @param pps_prefix_len 264头长度，可以为3个或4个字节，一般为0x00 00 00 01
     */
-    H264Track(const string &sps,const string &pps,int sps_prefix_len = 4,int pps_prefix_len = 4);
+    H264Track(const std::string &sps,const std::string &pps,int sps_prefix_len = 4,int pps_prefix_len = 4);
    /**
     * 构造h264类型的媒体
@@ -120,8 +120,8 @@ public:
    /**
     * 返回不带0x00 00 00 01头的sps/pps
     */
-    const string &getSps() const;
+    const std::string &getSps() const;
-    const string &getPps() const;
+    const std::string &getPps() const;
    bool ready() override;
    CodecId getCodecId() const override;
@@ -142,8 +142,8 @@ private:
    int _width = 0;
    int _height = 0;
    float _fps = 0;
-    string _sps;
+    std::string _sps;
-    string _pps;
+    std::string _pps;
 };
 }//namespace mediakit

--- a/src/Extension/H264Rtmp.cpp
+++ b/src/Extension/H264Rtmp.cpp
@@ -10,7 +10,11 @@
 #include "Rtmp/utils.h"
 #include "H264Rtmp.h"
-namespace mediakit{
+using namespace std;
+using namespace toolkit;
+namespace mediakit {
 H264RtmpDecoder::H264RtmpDecoder() {
    _h264frame = obtainFrame();

--- a/src/Extension/H264Rtmp.h
+++ b/src/Extension/H264Rtmp.h
@@ -15,7 +15,6 @@
 #include "Extension/Track.h"
 #include "Util/ResourcePool.h"
 #include "Extension/H264.h"
-using namespace toolkit;
 namespace mediakit{
 /**
@@ -45,8 +44,8 @@ protected:
 protected:
    H264Frame::Ptr _h264frame;
-    string _sps;
+    std::string _sps;
-    string _pps;
+    std::string _pps;
 };
 /**

--- a/src/Extension/H264Rtp.h
+++ b/src/Extension/H264Rtp.h
@@ -15,7 +15,6 @@
 #include "Util/ResourcePool.h"
 #include "Extension/H264.h"
 #include "Common/Stamp.h"
-using namespace toolkit;
 namespace mediakit{

--- a/src/Extension/H265.cpp
+++ b/src/Extension/H265.cpp
@@ -11,7 +11,10 @@
 #include "H265.h"
 #include "SPSParser.h"
-namespace mediakit{
+using namespace std;
+using namespace toolkit;
+namespace mediakit {
 bool getHEVCInfo(const char * vps, size_t vps_len,const char * sps,size_t sps_len,int &iVideoWidth, int &iVideoHeight, float  &iVideoFps){
    T_GetBitContext tGetBitBuf;

--- a/src/Extension/H265.h
+++ b/src/Extension/H265.h
@@ -15,18 +15,18 @@
 #include "Track.h"
 #include "Util/base64.h"
 #include "H264.h"
 #define H265_TYPE(v) (((uint8_t)(v) >> 1) & 0x3f)
-using namespace toolkit;
 namespace mediakit {
-bool getHEVCInfo(const string &strVps, const string &strSps, int &iVideoWidth, int &iVideoHeight, float &iVideoFps);
+bool getHEVCInfo(const std::string &strVps, const std::string &strSps, int &iVideoWidth, int &iVideoHeight, float &iVideoFps);
 template<typename Parent>
 class H265FrameHelper : public Parent{
 public:
    friend class FrameImp;
-    friend class ResourcePool_l<H265FrameHelper>;
+    friend class toolkit::ResourcePool_l<H265FrameHelper>;
    using Ptr = std::shared_ptr<H265FrameHelper>;
    enum {
@@ -136,14 +136,14 @@ public:
     * @param sps_prefix_len 265头长度，可以为3个或4个字节，一般为0x00 00 00 01
     * @param pps_prefix_len 265头长度，可以为3个或4个字节，一般为0x00 00 00 01
     */
-    H265Track(const string &vps,const string &sps, const string &pps,int vps_prefix_len = 4, int sps_prefix_len = 4, int pps_prefix_len = 4);
+    H265Track(const std::string &vps,const std::string &sps, const std::string &pps,int vps_prefix_len = 4, int sps_prefix_len = 4, int pps_prefix_len = 4);
    /**
     * 返回不带0x00 00 00 01头的vps/sps/pps
     */
-    const string &getVps() const;
+    const std::string &getVps() const;
-    const string &getSps() const;
+    const std::string &getSps() const;
-    const string &getPps() const;
+    const std::string &getPps() const;
    bool ready() override;
    CodecId getCodecId() const override;
@@ -164,9 +164,9 @@ private:
    int _width = 0;
    int _height = 0;
    float _fps = 0;
-    string _vps;
+    std::string _vps;
-    string _sps;
+    std::string _sps;
-    string _pps;
+    std::string _pps;
 };
 }//namespace mediakit

--- a/src/Extension/H265Rtmp.cpp
+++ b/src/Extension/H265Rtmp.cpp
@@ -14,6 +14,9 @@
 #include "mpeg4-hevc.h"
 #endif//ENABLE_MP4
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 H265RtmpDecoder::H265RtmpDecoder() {

--- a/src/Extension/H265Rtmp.h
+++ b/src/Extension/H265Rtmp.h
@@ -15,7 +15,6 @@
 #include "Extension/Track.h"
 #include "Util/ResourcePool.h"
 #include "Extension/H265.h"
-using namespace toolkit;
 namespace mediakit{
 /**
@@ -79,9 +78,9 @@ private:
 private:
    bool _got_config_frame = false;
-    string _vps;
+    std::string _vps;
-    string _sps;
+    std::string _sps;
-    string _pps;
+    std::string _pps;
    H265Track::Ptr _track;
    RtmpPacket::Ptr _rtmp_packet;
    FrameMerger _merger{FrameMerger::mp4_nal_size};

--- a/src/Extension/H265Rtp.h
+++ b/src/Extension/H265Rtp.h
@@ -16,8 +16,6 @@
 #include "Extension/H265.h"
 #include "Common/Stamp.h"
-using namespace toolkit;
 namespace mediakit{
 /**

--- a/src/Extension/L16.cpp
+++ b/src/Extension/L16.cpp
@@ -10,6 +10,9 @@
 #include "L16.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 /**

--- a/src/Extension/Opus.cpp
+++ b/src/Extension/Opus.cpp
@@ -10,6 +10,9 @@
 #include "Opus.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 /**

--- a/src/Extension/Track.h
+++ b/src/Extension/Track.h
@@ -16,7 +16,6 @@
 #include "Frame.h"
 #include "Util/RingBuffer.h"
 #include "Rtsp/Rtsp.h"
-using namespace toolkit;
 namespace mediakit{
@@ -186,7 +185,7 @@ public:
     * 获取全部的Track
     * @param trackReady 是否获取全部已经准备好的Track
     */
-    virtual vector<Track::Ptr> getTracks(bool trackReady = true) const = 0;
+    virtual std::vector<Track::Ptr> getTracks(bool trackReady = true) const = 0;
    /**
     * 获取特定Track

--- a/src/FMP4/FMP4MediaSource.h
+++ b/src/FMP4/FMP4MediaSource.h
@@ -12,18 +12,18 @@
 #define ZLMEDIAKIT_FMP4MEDIASOURCE_H
 #include "Common/MediaSource.h"
-using namespace toolkit;
 #define FMP4_GOP_SIZE 512
 namespace mediakit {
 //FMP4直播数据包
-class FMP4Packet : public BufferString{
+class FMP4Packet : public toolkit::BufferString{
 public:
    using Ptr = std::shared_ptr<FMP4Packet>;
    template<typename ...ARGS>
-    FMP4Packet(ARGS && ...args) : BufferString(std::forward<ARGS>(args)...) {};
+    FMP4Packet(ARGS && ...args) : toolkit::BufferString(std::forward<ARGS>(args)...) {};
    ~FMP4Packet() override = default;
 public:
@@ -31,15 +31,15 @@ public:
 };
 //FMP4直播源
-class FMP4MediaSource : public MediaSource, public RingDelegate<FMP4Packet::Ptr>, private PacketCache<FMP4Packet>{
+class FMP4MediaSource : public MediaSource, public toolkit::RingDelegate<FMP4Packet::Ptr>, private PacketCache<FMP4Packet>{
 public:
    using Ptr = std::shared_ptr<FMP4MediaSource>;
-    using RingDataType = std::shared_ptr<List<FMP4Packet::Ptr> >;
+    using RingDataType = std::shared_ptr<toolkit::List<FMP4Packet::Ptr> >;
-    using RingType = RingBuffer<RingDataType>;
+    using RingType = toolkit::RingBuffer<RingDataType>;
-    FMP4MediaSource(const string &vhost,
+    FMP4MediaSource(const std::string &vhost,
-                    const string &app,
+                    const std::string &app,
-                    const string &stream_id,
+                    const std::string &stream_id,
                    int ring_size = FMP4_GOP_SIZE) : MediaSource(FMP4_SCHEMA, vhost, app, stream_id), _ring_size(ring_size) {}
    ~FMP4MediaSource() override = default;
@@ -54,7 +54,7 @@ public:
    /**
     * 获取fmp4 init segment
     */
-    const string &getInitSegment() const{
+    const std::string &getInitSegment() const{
        return _init_segment;
    }
@@ -62,7 +62,7 @@ public:
     * 设置fmp4 init segment
     * @param str init segment
     */
-    void setInitSegment(string str) {
+    void setInitSegment(std::string str) {
        _init_segment = std::move(str);
        createRing();
    }
@@ -101,7 +101,7 @@ public:
 private:
    void createRing(){
-        weak_ptr<FMP4MediaSource> weak_self = dynamic_pointer_cast<FMP4MediaSource>(shared_from_this());
+        std::weak_ptr<FMP4MediaSource> weak_self = std::dynamic_pointer_cast<FMP4MediaSource>(shared_from_this());
        _ring = std::make_shared<RingType>(_ring_size, [weak_self](int size) {
            auto strong_self = weak_self.lock();
            if (!strong_self) {
@@ -120,7 +120,7 @@ private:
     * @param packet_list 合并写缓存列队
     * @param key_pos 是否包含关键帧
     */
-    void onFlush(std::shared_ptr<List<FMP4Packet::Ptr> > packet_list, bool key_pos) override {
+    void onFlush(std::shared_ptr<toolkit::List<FMP4Packet::Ptr> > packet_list, bool key_pos) override {
        //如果不存在视频，那么就没有存在GOP缓存的意义，所以确保一直清空GOP缓存
        _ring->write(std::move(packet_list), _have_video ? key_pos : true);
    }
@@ -128,7 +128,7 @@ private:
 private:
    bool _have_video = false;
    int _ring_size;
-    string _init_segment;
+    std::string _init_segment;
    RingType::Ptr _ring;
 };

--- a/src/FMP4/FMP4MediaSourceMuxer.h
+++ b/src/FMP4/FMP4MediaSourceMuxer.h
@@ -23,9 +23,9 @@ class FMP4MediaSourceMuxer : public MP4MuxerMemory, public MediaSourceEventInter
 public:
    using Ptr = std::shared_ptr<FMP4MediaSourceMuxer>;
-    FMP4MediaSourceMuxer(const string &vhost,
+    FMP4MediaSourceMuxer(const std::string &vhost,
-                         const string &app,
+                         const std::string &app,
-                         const string &stream_id) {
+                         const std::string &stream_id) {
        _media_src = std::make_shared<FMP4MediaSource>(vhost, app, stream_id);
    }
@@ -72,7 +72,7 @@ public:
    }
 protected:
-    void onSegmentData(string string, uint32_t stamp, bool key_frame) override {
+    void onSegmentData(std::string string, uint32_t stamp, bool key_frame) override {
        if (string.empty()) {
            return;
        }

--- a/src/Http/HlsParser.cpp
+++ b/src/Http/HlsParser.cpp
@@ -13,7 +13,10 @@
 #include "HlsParser.h"
 #include "Util/util.h"
 #include "Common/Parser.h"
+using namespace std;
 using namespace toolkit;
 namespace mediakit {
 bool HlsParser::parse(const string &http_url, const string &m3u8) {

--- a/src/Http/HlsParser.h
+++ b/src/Http/HlsParser.h
@@ -14,12 +14,12 @@
 #include <string>
 #include <list>
 #include <map>
-using namespace std;
 namespace mediakit {
 typedef struct{
    //url地址
-    string url;
+    std::string url;
    //ts切片长度
    float duration;
@@ -38,7 +38,7 @@ class HlsParser {
 public:
    HlsParser(){}
    ~HlsParser(){}
-    bool parse(const string &http_url,const string &m3u8);
+    bool parse(const std::string &http_url,const std::string &m3u8);
    /**
     * 是否存在#EXTM3U字段，是否为m3u8文件
@@ -82,7 +82,7 @@ public:
 protected:
    //解析出ts文件地址回调
-    virtual void onParsed(bool is_m3u8_inner,int64_t sequence,const map<int,ts_segment> &ts_list) {};
+    virtual void onParsed(bool is_m3u8_inner,int64_t sequence,const std::map<int,ts_segment> &ts_list) {};
 private:
    bool _is_m3u8 = false;

--- a/src/Http/HlsPlayer.cpp
+++ b/src/Http/HlsPlayer.cpp
@@ -10,6 +10,9 @@
 #include "HlsPlayer.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 HlsPlayer::HlsPlayer(const EventPoller::Ptr &poller) {
@@ -27,8 +30,8 @@ void HlsPlayer::fetchIndexFile() {
    if (waitResponse()) {
        return;
    }
-    if (!(*this)[kNetAdapter].empty()) {
+    if (!(*this)[Client::kNetAdapter].empty()) {
-        setNetAdapter((*this)[kNetAdapter]);
+        setNetAdapter((*this)[Client::kNetAdapter]);
    }
    setCompleteTimeout((*this)[Client::kTimeoutMS].as<int>());
    setMethod("GET");
@@ -83,7 +86,7 @@ void HlsPlayer::fetchSegment() {
            strong_self->onPacket_l(data, len);
        });
-        if (!(*this)[kNetAdapter].empty()) {
+        if (!(*this)[Client::kNetAdapter].empty()) {
            _http_ts_player->setNetAdapter((*this)[Client::kNetAdapter]);
        }
    }

--- a/src/Http/HlsPlayer.h
+++ b/src/Http/HlsPlayer.h
@@ -17,8 +17,6 @@
 #include "HlsParser.h"
 #include "Rtp/TSDecoder.h"
-using namespace toolkit;
 namespace mediakit {
 class HlsDemuxer
@@ -29,12 +27,12 @@ public:
    HlsDemuxer() = default;
    ~HlsDemuxer() override { _timer = nullptr; }
-    void start(const EventPoller::Ptr &poller, TrackListener *listener);
+    void start(const toolkit::EventPoller::Ptr &poller, TrackListener *listener);
    bool inputFrame(const Frame::Ptr &frame) override;
    bool addTrack(const Track::Ptr &track) override { return _delegate.addTrack(track); }
    void addTrackCompleted() override { _delegate.addTrackCompleted(); }
    void resetTracks() override { ((MediaSink &)_delegate).resetTracks(); }
-    vector<Track::Ptr> getTracks(bool ready = true) const override { return _delegate.getTracks(ready); }
+    std::vector<Track::Ptr> getTracks(bool ready = true) const override { return _delegate.getTracks(ready); }
 private:
    void onTick();
@@ -44,22 +42,22 @@ private:
 private:
    int64_t _ticker_offset = 0;
-    Ticker _ticker;
+    toolkit::Ticker _ticker;
    Stamp _stamp[2];
-    Timer::Ptr _timer;
+    toolkit::Timer::Ptr _timer;
    MediaSinkDelegate _delegate;
-    multimap<int64_t, Frame::Ptr> _frame_cache;
+    std::multimap<int64_t, Frame::Ptr> _frame_cache;
 };
 class HlsPlayer : public  HttpClientImp , public PlayerBase , public HlsParser{
 public:
-    HlsPlayer(const EventPoller::Ptr &poller);
+    HlsPlayer(const toolkit::EventPoller::Ptr &poller);
    ~HlsPlayer() override = default;
    /**
     * 开始播放
     */
-    void play(const string &url) override;
+    void play(const std::string &url) override;
    /**
     * 停止播放
@@ -76,37 +74,37 @@ protected:
 private:
    void onParsed(bool is_m3u8_inner,int64_t sequence,const map<int,ts_segment> &ts_map) override;
-    void onResponseHeader(const string &status,const HttpHeader &headers) override;
+    void onResponseHeader(const std::string &status,const HttpHeader &headers) override;
    void onResponseBody(const char *buf,size_t size) override;
-    void onResponseCompleted(const SockException &e) override;
+    void onResponseCompleted(const toolkit::SockException &e) override;
-    bool onRedirectUrl(const string &url,bool temporary) override;
+    bool onRedirectUrl(const std::string &url,bool temporary) override;
 private:
    void playDelay();
    float delaySecond();
    void fetchSegment();
-    void teardown_l(const SockException &ex);
+    void teardown_l(const toolkit::SockException &ex);
    void fetchIndexFile();
    void onPacket_l(const char *data, size_t len);
 private:
    struct UrlComp {
        //url忽略？后面的参数
-        bool operator()(const string& __x, const string& __y) const {
+        bool operator()(const std::string& __x, const std::string& __y) const {
-            return split(__x,"?")[0] < split(__y,"?")[0];
+            return toolkit::split(__x,"?")[0] < toolkit::split(__y,"?")[0];
        }
    };
 private:
    bool _play_result = false;
    int64_t _last_sequence = -1;
-    string _m3u8;
+    std::string _m3u8;
-    string _play_url;
+    std::string _play_url;
-    Timer::Ptr _timer;
+    toolkit::Timer::Ptr _timer;
-    Timer::Ptr _timer_ts;
+    toolkit::Timer::Ptr _timer_ts;
-    list<ts_segment> _ts_list;
+    std::list<ts_segment> _ts_list;
-    list<string> _ts_url_sort;
+    std::list<std::string> _ts_url_sort;
-    set<string, UrlComp> _ts_url_cache;
+    std::set<std::string, UrlComp> _ts_url_cache;
    HttpTSPlayer::Ptr _http_ts_player;
    TSSegment _segment;
 };
@@ -114,7 +112,7 @@ private:
 class HlsPlayerImp : public PlayerImp<HlsPlayer, PlayerBase>, private TrackListener {
 public:
    typedef std::shared_ptr<HlsPlayerImp> Ptr;
-    HlsPlayerImp(const EventPoller::Ptr &poller = nullptr);
+    HlsPlayerImp(const toolkit::EventPoller::Ptr &poller = nullptr);
    ~HlsPlayerImp() override = default;
 private:
@@ -123,9 +121,9 @@ private:
 private:
    //// PlayerBase override////
-    void onPlayResult(const SockException &ex) override;
+    void onPlayResult(const toolkit::SockException &ex) override;
-    vector<Track::Ptr> getTracks(bool ready = true) const override;
+    std::vector<Track::Ptr> getTracks(bool ready = true) const override;
-    void onShutdown(const SockException &ex) override;
+    void onShutdown(const toolkit::SockException &ex) override;
 private:
    //// TrackListener override////

--- a/src/Http/HttpBody.cpp
+++ b/src/Http/HttpBody.cpp
@@ -8,11 +8,13 @@
 * may be found in the AUTHORS file in the root of the source tree.
 */
+#include <csignal>
 #include "HttpBody.h"
 #include "Util/util.h"
 #include "Util/File.h"
 #include "Util/uv_errno.h"
 #include "Util/logger.h"
+#include "Util/onceToken.h"
 #include "HttpClient.h"
 #ifndef _WIN32
 #include <sys/mman.h>
@@ -22,6 +24,9 @@
 #define ENABLE_MMAP
 #endif
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 HttpStringBody::HttpStringBody(string str){
@@ -62,9 +67,26 @@ HttpFileBody::HttpFileBody(const std::shared_ptr<FILE> &fp, size_t offset, size_
    init(fp, offset, max_size, use_mmap);
 }
+#if defined(__linux__) || defined(__linux)
+#include <sys/sendfile.h>
+#endif
+int HttpFileBody::sendFile(int fd) {
+#if defined(__linux__) || defined(__linux)
+    static onceToken s_token([]() {
+        signal(SIGPIPE, SIG_IGN);
+    });
+    off_t off = _file_offset;
+    return sendfile(fd, fileno(_fp.get()), &off, _max_size);
+#else
+    return -1;
+#endif
+}
 void HttpFileBody::init(const std::shared_ptr<FILE> &fp, size_t offset, size_t max_size, bool use_mmap) {
    _fp = fp;
    _max_size = max_size;
+    _file_offset = offset;
 #ifdef ENABLE_MMAP
    if (use_mmap) {
        do {

--- a/src/Http/HttpBody.h
+++ b/src/Http/HttpBody.h
@@ -18,9 +18,6 @@
 #include "Util/logger.h"
 #include "Thread/WorkThreadPool.h"
-using namespace std;
-using namespace toolkit;
 #ifndef MIN
 #define MIN(a,b) ((a) < (b) ? (a) : (b) )
 #endif //MIN
@@ -47,36 +44,45 @@ public:
     * @param size 请求大小
     * @return 字节对象,如果读完了，那么请返回nullptr
     */
-    virtual Buffer::Ptr readData(size_t size) { return nullptr;};
+    virtual toolkit::Buffer::Ptr readData(size_t size) { return nullptr;};
    /**
     * 异步请求读取一定字节数，返回大小可能小于size
     * @param size 请求大小
     * @param cb 回调函数
     */
-    virtual void readDataAsync(size_t size,const function<void(const Buffer::Ptr &buf)> &cb){
+    virtual void readDataAsync(size_t size,const std::function<void(const toolkit::Buffer::Ptr &buf)> &cb){
        //由于unix和linux是通过mmap的方式读取文件，所以把读文件操作放在后台线程并不能提高性能
        //反而会由于频繁的线程切换导致性能降低以及延时增加，所以我们默认同步获取文件内容
        //(其实并没有读，拷贝文件数据时在内核态完成文件读)
        cb(readData(size));
    }
+    /**
+     * 使用sendfile优化文件发送
+     * @param fd socket fd
+     * @return 0成功，其他为错误代码
+     */
+    virtual int sendFile(int fd) {
+        return -1;
+    }
 };
 /**
- * string类型的content
+ * std::string类型的content
 */
 class HttpStringBody : public HttpBody{
 public:
    typedef std::shared_ptr<HttpStringBody> Ptr;
-    HttpStringBody(string str);
+    HttpStringBody(std::string str);
    ~HttpStringBody() override = default;
    ssize_t remainSize() override;
-    Buffer::Ptr readData(size_t size) override ;
+    toolkit::Buffer::Ptr readData(size_t size) override ;
 private:
    size_t _offset = 0;
-    mutable string _str;
+    mutable std::string _str;
 };
 /**
@@ -85,14 +91,14 @@ private:
 class HttpBufferBody : public HttpBody{
 public:
    typedef std::shared_ptr<HttpBufferBody> Ptr;
-    HttpBufferBody(Buffer::Ptr buffer);
+    HttpBufferBody(toolkit::Buffer::Ptr buffer);
    ~HttpBufferBody() override = default;
    ssize_t remainSize() override;
-    Buffer::Ptr readData(size_t size) override;
+    toolkit::Buffer::Ptr readData(size_t size) override;
 private:
-    Buffer::Ptr _buffer;
+    toolkit::Buffer::Ptr _buffer;
 };
 /**
@@ -110,11 +116,12 @@ public:
     * @param use_mmap 是否使用mmap方式访问文件
     */
    HttpFileBody(const std::shared_ptr<FILE> &fp, size_t offset, size_t max_size, bool use_mmap = true);
-    HttpFileBody(const string &file_path, bool use_mmap = true);
+    HttpFileBody(const std::string &file_path, bool use_mmap = true);
    ~HttpFileBody() override = default;
    ssize_t remainSize() override ;
-    Buffer::Ptr readData(size_t size) override;
+    toolkit::Buffer::Ptr readData(size_t size) override;
+    int sendFile(int fd) override;
 private:
    void init(const std::shared_ptr<FILE> &fp,size_t offset,size_t max_size, bool use_mmap);
@@ -122,9 +129,10 @@ private:
 private:
    size_t _max_size;
    size_t _offset = 0;
+    size_t _file_offset = 0;
    std::shared_ptr<FILE> _fp;
    std::shared_ptr<char> _map_addr;
-    ResourcePool<BufferRaw> _pool;
+    toolkit::ResourcePool<toolkit::BufferRaw> _pool;
 };
 class HttpArgs;
@@ -142,21 +150,21 @@ public:
     * @param filePath 文件路径
     * @param boundary boundary字符串
     */
-    HttpMultiFormBody(const HttpArgs &args,const string &filePath,const string &boundary = "0xKhTmLbOuNdArY");
+    HttpMultiFormBody(const HttpArgs &args,const std::string &filePath,const std::string &boundary = "0xKhTmLbOuNdArY");
    virtual ~HttpMultiFormBody(){}
    ssize_t remainSize() override ;
-    Buffer::Ptr readData(size_t size) override;
+    toolkit::Buffer::Ptr readData(size_t size) override;
 public:
-    static string multiFormBodyPrefix(const HttpArgs &args,const string &boundary,const string &fileName);
+    static std::string multiFormBodyPrefix(const HttpArgs &args,const std::string &boundary,const std::string &fileName);
-    static string multiFormBodySuffix(const string &boundary);
+    static std::string multiFormBodySuffix(const std::string &boundary);
-    static string multiFormContentType(const string &boundary);
+    static std::string multiFormContentType(const std::string &boundary);
 private:
    size_t _offset = 0;
    size_t _totalSize;
-    string _bodyPrefix;
+    std::string _bodyPrefix;
-    string _bodySuffix;
+    std::string _bodySuffix;
    HttpFileBody::Ptr _fileBody;
 };

--- a/src/Http/HttpChunkedSplitter.cpp
+++ b/src/Http/HttpChunkedSplitter.cpp
@@ -11,6 +11,8 @@
 #include <string.h>
 #include "HttpChunkedSplitter.h"
+using namespace std;
 namespace mediakit{
 const char *HttpChunkedSplitter::onSearchPacketTail(const char *data, size_t len) {

--- a/src/Http/HttpClient.cpp
+++ b/src/Http/HttpClient.cpp
@@ -13,6 +13,9 @@
 #include "HttpClient.h"
 #include "Common/config.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 void HttpClient::sendRequest(const string &url) {

--- a/src/Http/HttpClient.h
+++ b/src/Http/HttpClient.h
@@ -25,18 +25,15 @@
 #include "strCoding.h"
 #include "HttpBody.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit {
-class HttpArgs : public map<string, variant, StrCaseCompare> {
+class HttpArgs : public std::map<std::string, toolkit::variant, StrCaseCompare> {
 public:
    HttpArgs() = default;
    ~HttpArgs() = default;
-    string make() const {
+    std::string make() const {
-        string ret;
+        std::string ret;
        for (auto &pr : *this) {
            ret.append(pr.first);
            ret.append("=");
@@ -50,7 +47,7 @@ public:
    }
 };
-class HttpClient : public TcpClient, public HttpRequestSplitter {
+class HttpClient : public toolkit::TcpClient, public HttpRequestSplitter {
 public:
    using HttpHeader = StrCaseMap;
    using Ptr = std::shared_ptr<HttpClient>;
@@ -62,7 +59,7 @@ public:
     * 发送http[s]请求
     * @param url 请求url
     */
-    virtual void sendRequest(const string &url);
+    virtual void sendRequest(const std::string &url);
    /**
     * 重置对象
@@ -73,7 +70,7 @@ public:
     * 设置http方法
     * @param method GET/POST等
     */
-    void setMethod(string method);
+    void setMethod(std::string method);
    /**
     * 覆盖http头
@@ -81,13 +78,13 @@ public:
     */
    void setHeader(HttpHeader header);
-    HttpClient &addHeader(string key, string val, bool force = false);
+    HttpClient &addHeader(std::string key, std::string val, bool force = false);
    /**
     * 设置http content
     * @param body http content
     */
-    void setBody(string body);
+    void setBody(std::string body);
    /**
     * 设置http content
@@ -113,7 +110,7 @@ public:
    /**
     * 获取请求url
     */
-    const string &getUrl() const;
+    const std::string &getUrl() const;
    /**
     * 判断是否正在等待响应
@@ -150,7 +147,7 @@ protected:
     * @param status 状态码，譬如:200 OK
     * @param headers http头
     */
-    virtual void onResponseHeader(const string &status, const HttpHeader &headers) = 0;
+    virtual void onResponseHeader(const std::string &status, const HttpHeader &headers) = 0;
    /**
     * 收到http conten数据
@@ -162,7 +159,7 @@ protected:
    /**
     * 接收http回复完毕,
     */
-    virtual void onResponseCompleted(const SockException &ex) = 0;
+    virtual void onResponseCompleted(const toolkit::SockException &ex) = 0;
    /**
     * 重定向事件
@@ -170,7 +167,7 @@ protected:
     * @param temporary 是否为临时重定向
     * @return 是否继续
     */
-    virtual bool onRedirectUrl(const string &url, bool temporary) { return true; };
+    virtual bool onRedirectUrl(const std::string &url, bool temporary) { return true; };
 protected:
    //// HttpRequestSplitter override ////
@@ -178,15 +175,15 @@ protected:
    void onRecvContent(const char *data, size_t len) override;
    //// TcpClient override ////
-    void onConnect(const SockException &ex) override;
+    void onConnect(const toolkit::SockException &ex) override;
-    void onRecv(const Buffer::Ptr &pBuf) override;
+    void onRecv(const toolkit::Buffer::Ptr &pBuf) override;
-    void onErr(const SockException &ex) override;
+    void onErr(const toolkit::SockException &ex) override;
    void onFlush() override;
    void onManager() override;
 private:
-    void onResponseCompleted_l(const SockException &ex);
+    void onResponseCompleted_l(const toolkit::SockException &ex);
-    void onConnect_l(const SockException &ex);
+    void onConnect_l(const toolkit::SockException &ex);
    void checkCookie(HttpHeader &headers);
    void clearResponse();
@@ -201,23 +198,23 @@ private:
    //for request args
    bool _is_https;
-    string _url;
+    std::string _url;
    HttpHeader _user_set_header;
    HttpBody::Ptr _body;
-    string _method;
+    std::string _method;
-    string _last_host;
+    std::string _last_host;
    //for this request
-    string _path;
+    std::string _path;
    HttpHeader _header;
    //for timeout
    size_t _wait_header_ms = 10 * 1000;
    size_t _wait_body_ms = 10 * 1000;
    size_t _wait_complete_ms = 0;
-    Ticker _wait_header;
+    toolkit::Ticker _wait_header;
-    Ticker _wait_body;
+    toolkit::Ticker _wait_body;
-    Ticker _wait_complete;
+    toolkit::Ticker _wait_complete;
 };
 } /* namespace mediakit */

--- a/src/Http/HttpClientImp.cpp
+++ b/src/Http/HttpClientImp.cpp
@@ -10,6 +10,8 @@
 #include "Http/HttpClientImp.h"
+using namespace toolkit;
 namespace mediakit {
 void HttpClientImp::onConnect(const SockException &ex) {

--- a/src/Http/HttpClientImp.h
+++ b/src/Http/HttpClientImp.h
@@ -13,17 +13,17 @@
 #include "HttpClient.h"
 #include "Util/SSLBox.h"
-using namespace toolkit;
 namespace mediakit {
-class HttpClientImp : public TcpClientWithSSL<HttpClient> {
+class HttpClientImp : public toolkit::TcpClientWithSSL<HttpClient> {
 public:
    using Ptr = std::shared_ptr<HttpClientImp>;
    HttpClientImp() = default;
    ~HttpClientImp() override = default;
 protected:
-    void onConnect(const SockException &ex) override;
+    void onConnect(const toolkit::SockException &ex) override;
 };
 } /* namespace mediakit */

--- a/src/Http/HttpConst.cpp
+++ b/src/Http/HttpConst.cpp
@@ -13,6 +13,9 @@
 #include "Common/Parser.h"
 #include "Util/onceToken.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit{
 const char *getHttpStatusMessage(int status) {

--- a/src/Http/HttpConst.h
+++ b/src/Http/HttpConst.h
@@ -12,7 +12,6 @@
 #define ZLMEDIAKIT_HTTPCONST_H
 #include <string>
-using namespace std;
 namespace mediakit{
@@ -28,7 +27,7 @@ const char *getHttpStatusMessage(int status);
 * @param name 文件后缀，譬如html
 * @return mime值，譬如text/html
 */
-const string &getHttpContentType(const char *name);
+const std::string &getHttpContentType(const char *name);
 }//mediakit

--- a/src/Http/HttpCookie.cpp
+++ b/src/Http/HttpCookie.cpp
@@ -17,6 +17,8 @@
 #endif
 using namespace toolkit;
+using namespace std;
 namespace mediakit {
 void HttpCookie::setPath(const string &path){

--- a/src/Http/HttpCookie.h
+++ b/src/Http/HttpCookie.h
@@ -17,7 +17,6 @@
 #include <map>
 #include <unordered_map>
 #include <mutex>
-using namespace std;
 namespace mediakit {
@@ -31,19 +30,19 @@ public:
    HttpCookie(){}
    ~HttpCookie(){}
-    void setPath(const string &path);
+    void setPath(const std::string &path);
-    void setHost(const string &host);
+    void setHost(const std::string &host);
-    void setExpires(const string &expires,const string &server_date);
+    void setExpires(const std::string &expires,const std::string &server_date);
-    void setKeyVal(const string &key,const string &val);
+    void setKeyVal(const std::string &key,const std::string &val);
    operator bool ();
-    const string &getKey() const ;
+    const std::string &getKey() const ;
-    const string &getVal() const ;
+    const std::string &getVal() const ;
 private:
-    string _host;
+    std::string _host;
-    string _path = "/";
+    std::string _path = "/";
-    string _key;
+    std::string _key;
-    string _val;
+    std::string _val;
    time_t _expire = 0;
 };
@@ -56,12 +55,12 @@ public:
    ~HttpCookieStorage(){}
    static HttpCookieStorage &Instance();
    void set(const HttpCookie::Ptr &cookie);
-    vector<HttpCookie::Ptr> get(const string &host,const string &path);
+    std::vector<HttpCookie::Ptr> get(const std::string &host,const std::string &path);
 private:
    HttpCookieStorage(){};
 private:
-    unordered_map<string/*host*/,map<string/*cookie path*/,map<string/*cookie_key*/,HttpCookie::Ptr> > > _all_cookie;
+    std::unordered_map<std::string/*host*/, std::map<std::string/*cookie path*/,std::map<std::string/*cookie_key*/, HttpCookie::Ptr> > > _all_cookie;
-    mutex _mtx_cookie;
+    std::mutex _mtx_cookie;
 };

--- a/src/Http/HttpCookieManager.cpp
+++ b/src/Http/HttpCookieManager.cpp
@@ -13,6 +13,9 @@
 #include "Common/config.h"
 #include "HttpCookieManager.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 //////////////////////////////HttpServerCookie////////////////////////////////////

--- a/src/Http/HttpCookieManager.h
+++ b/src/Http/HttpCookieManager.h
@@ -19,10 +19,6 @@
 #include "Network/Socket.h"
 #include "Common/Parser.h"
-using namespace std;
-using namespace toolkit;
-using namespace mediakit;
 #define COOKIE_DEFAULT_LIFE (7 * 24 * 60 * 60)
 namespace mediakit {
@@ -32,7 +28,7 @@ class HttpCookieManager;
 /**
 * cookie对象，用于保存cookie的一些相关属性
 */
-class HttpServerCookie : public AnyStorage , public noncopyable{
+class HttpServerCookie : public toolkit::AnyStorage , public toolkit::noncopyable{
 public:
    typedef std::shared_ptr<HttpServerCookie> Ptr;
    /**
@@ -45,9 +41,9 @@ public:
     */
    HttpServerCookie(const std::shared_ptr<HttpCookieManager> &manager,
-                     const string &cookie_name,
+                     const std::string &cookie_name,
-                     const string &uid,
+                     const std::string &uid,
-                     const string &cookie,
+                     const std::string &cookie,
                     uint64_t max_elapsed);
    ~HttpServerCookie() ;
@@ -55,7 +51,7 @@ public:
     * 获取uid
     * @return uid
     */
-    const string &getUid() const;
+    const std::string &getUid() const;
    /**
     * 获取http中Set-Cookie字段的值
@@ -63,19 +59,19 @@ public:
     * @param path http访问路径
     * @return 例如 MY_SESSION=XXXXXX;expires=Wed, Jun 12 2019 06:30:48 GMT;path=/index/files/
     */
-    string getCookie(const string &path) const;
+    std::string getCookie(const std::string &path) const;
    /**
     * 获取cookie随机字符串
     * @return cookie随机字符串
     */
-    const string& getCookie() const;
+    const std::string& getCookie() const;
    /**
     * 获取该cookie名
     * @return
     */
-    const string& getCookieName() const;
+    const std::string& getCookieName() const;
    /**
     * 更新该cookie的过期时间，可以让此cookie不失效
@@ -92,16 +88,16 @@ public:
     * 获取区域锁
     * @return
     */
-    std::shared_ptr<lock_guard<recursive_mutex> > getLock();
+    std::shared_ptr<std::lock_guard<std::recursive_mutex> > getLock();
 private:
-    string cookieExpireTime() const ;
+    std::string cookieExpireTime() const ;
 private:
-    string _uid;
+    std::string _uid;
-    string _cookie_name;
+    std::string _cookie_name;
-    string _cookie_uuid;
+    std::string _cookie_uuid;
    uint64_t _max_elapsed;
-    Ticker _ticker;
+    toolkit::Ticker _ticker;
-    recursive_mutex _mtx;
+    std::recursive_mutex _mtx;
    std::weak_ptr<HttpCookieManager> _manager;
 };
@@ -117,18 +113,18 @@ public:
     * 获取不碰撞的随机字符串
     * @return 随机字符串
     */
-    string obtain();
+    std::string obtain();
    /**
     * 释放随机字符串
     * @param str 随机字符串
     */
-    void release(const string &str);
+    void release(const std::string &str);
 private:
-    string obtain_l();
+    std::string obtain_l();
 private:
    //碰撞库
-    unordered_set<string> _obtained;
+    std::unordered_set<std::string> _obtained;
    //增长index，防止碰撞用
    int _index = 0;
 };
@@ -156,7 +152,7 @@ public:
     * @param max_elapsed 该cookie过期时间，单位秒
     * @return cookie对象
     */
-    HttpServerCookie::Ptr addCookie(const string &cookie_name,const string &uid, uint64_t max_elapsed = COOKIE_DEFAULT_LIFE,int max_client = 1);
+    HttpServerCookie::Ptr addCookie(const std::string &cookie_name,const std::string &uid, uint64_t max_elapsed = COOKIE_DEFAULT_LIFE,int max_client = 1);
    /**
     * 根据cookie随机字符串查找cookie对象
@@ -164,7 +160,7 @@ public:
     * @param cookie cookie随机字符串
     * @return cookie对象，可以为nullptr
     */
-    HttpServerCookie::Ptr getCookie(const string &cookie_name,const string &cookie);
+    HttpServerCookie::Ptr getCookie(const std::string &cookie_name,const std::string &cookie);
    /**
     * 从http头中获取cookie对象
@@ -172,7 +168,7 @@ public:
     * @param http_header http头
     * @return cookie对象
     */
-    HttpServerCookie::Ptr getCookie(const string &cookie_name,const StrCaseMap &http_header);
+    HttpServerCookie::Ptr getCookie(const std::string &cookie_name,const StrCaseMap &http_header);
    /**
     * 根据uid获取cookie
@@ -180,7 +176,7 @@ public:
     * @param uid 用户id
     * @return cookie对象
     */
-    HttpServerCookie::Ptr getCookieByUid(const string &cookie_name,const string &uid);
+    HttpServerCookie::Ptr getCookieByUid(const std::string &cookie_name,const std::string &uid);
    /**
     * 删除cookie，用户登出时使用
@@ -197,7 +193,7 @@ private:
     * @param uid 用户id
     * @param cookie cookie随机字符串
     */
-    void onAddCookie(const string &cookie_name,const string &uid,const string &cookie);
+    void onAddCookie(const std::string &cookie_name,const std::string &uid,const std::string &cookie);
    /**
     * 析构cookie对象时触发
@@ -205,7 +201,7 @@ private:
     * @param uid 用户id
     * @param cookie cookie随机字符串
     */
-    void onDelCookie(const string &cookie_name,const string &uid,const string &cookie);
+    void onDelCookie(const std::string &cookie_name,const std::string &uid,const std::string &cookie);
    /**
     * 获取某用户名下最先登录时的cookie，目的是实现某用户下最多登录若干个设备
@@ -214,7 +210,7 @@ private:
     * @param max_client 最多登录的设备个数
     * @return 最早的cookie随机字符串
     */
-    string getOldestCookie(const string &cookie_name,const string &uid, int max_client = 1);
+    std::string getOldestCookie(const std::string &cookie_name,const std::string &uid, int max_client = 1);
    /**
     * 删除cookie
@@ -222,12 +218,12 @@ private:
     * @param cookie cookie随机字符串
     * @return 成功true
     */
-    bool delCookie(const string &cookie_name,const string &cookie);
+    bool delCookie(const std::string &cookie_name,const std::string &cookie);
 private:
-    unordered_map<string/*cookie_name*/,unordered_map<string/*cookie*/,HttpServerCookie::Ptr/*cookie_data*/> >_map_cookie;
+    std::unordered_map<std::string/*cookie_name*/,std::unordered_map<std::string/*cookie*/,HttpServerCookie::Ptr/*cookie_data*/> >_map_cookie;
-    unordered_map<string/*cookie_name*/,unordered_map<string/*uid*/,map<uint64_t/*cookie time stamp*/,string/*cookie*/> > >_map_uid_to_cookie;
+    std::unordered_map<std::string/*cookie_name*/,std::unordered_map<std::string/*uid*/,std::map<uint64_t/*cookie time stamp*/,std::string/*cookie*/> > >_map_uid_to_cookie;
-    recursive_mutex _mtx_cookie;
+    std::recursive_mutex _mtx_cookie;
-    Timer::Ptr _timer;
+    toolkit::Timer::Ptr _timer;
    RandStrGeneator _geneator;
 };

--- a/src/Http/HttpDownloader.cpp
+++ b/src/Http/HttpDownloader.cpp
@@ -12,6 +12,7 @@
 #include "Util/File.h"
 #include "Util/MD5.h"
 using namespace toolkit;
+using namespace std;
 namespace mediakit {

--- a/src/Http/HttpDownloader.h
+++ b/src/Http/HttpDownloader.h
@@ -18,7 +18,7 @@ namespace mediakit {
 class HttpDownloader : public HttpClientImp {
 public:
    using Ptr = std::shared_ptr<HttpDownloader>;
-    using onDownloadResult = std::function<void(const SockException &ex, const string &filePath)>;
+    using onDownloadResult = std::function<void(const toolkit::SockException &ex, const std::string &filePath)>;
    HttpDownloader() = default;
    ~HttpDownloader() override;
@@ -29,9 +29,9 @@ public:
     * @param file_path 文件保存地址，置空则选择默认文件路径
     * @param append 如果文件已经存在，是否断点续传方式下载
     */
-    void startDownload(const string &url, const string &file_path = "", bool append = false);
+    void startDownload(const std::string &url, const std::string &file_path = "", bool append = false);
-    void startDownload(const string &url, const onDownloadResult &cb) {
+    void startDownload(const std::string &url, const onDownloadResult &cb) {
        setOnResult(cb);
        startDownload(url, "", false);
    }
@@ -40,15 +40,15 @@ public:
 protected:
    void onResponseBody(const char *buf, size_t size) override;
-    void onResponseHeader(const string &status, const HttpHeader &headers) override;
+    void onResponseHeader(const std::string &status, const HttpHeader &headers) override;
-    void onResponseCompleted(const SockException &ex) override;
+    void onResponseCompleted(const toolkit::SockException &ex) override;
 private:
    void closeFile();
 private:
    FILE *_save_file = nullptr;
-    string _file_path;
+    std::string _file_path;
    onDownloadResult _on_result;
 };

--- a/src/Http/HttpFileManager.cpp
+++ b/src/Http/HttpFileManager.cpp
@@ -20,6 +20,9 @@
 #include "Record/HlsMediaSource.h"
 #include "Common/Parser.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 // hls的播放cookie缓存时间默认60秒，

--- a/src/Http/HttpFileManager.h
+++ b/src/Http/HttpFileManager.h
@@ -22,20 +22,20 @@ namespace mediakit {
 class HttpResponseInvokerImp{
 public:
    typedef std::function<void(int code, const StrCaseMap &headerOut, const HttpBody::Ptr &body)> HttpResponseInvokerLambda0;
-    typedef std::function<void(int code, const StrCaseMap &headerOut, const string &body)> HttpResponseInvokerLambda1;
+    typedef std::function<void(int code, const StrCaseMap &headerOut, const std::string &body)> HttpResponseInvokerLambda1;
    HttpResponseInvokerImp(){}
    ~HttpResponseInvokerImp(){}
    template<typename C>
-    HttpResponseInvokerImp(const C &c):HttpResponseInvokerImp(typename function_traits<C>::stl_function_type(c)) {}
+    HttpResponseInvokerImp(const C &c):HttpResponseInvokerImp(typename toolkit::function_traits<C>::stl_function_type(c)) {}
    HttpResponseInvokerImp(const HttpResponseInvokerLambda0 &lambda);
    HttpResponseInvokerImp(const HttpResponseInvokerLambda1 &lambda);
-    void operator()(int code, const StrCaseMap &headerOut, const Buffer::Ptr &body) const;
+    void operator()(int code, const StrCaseMap &headerOut, const toolkit::Buffer::Ptr &body) const;
    void operator()(int code, const StrCaseMap &headerOut, const HttpBody::Ptr &body) const;
-    void operator()(int code, const StrCaseMap &headerOut, const string &body) const;
+    void operator()(int code, const StrCaseMap &headerOut, const std::string &body) const;
-    void responseFile(const StrCaseMap &requestHeader,const StrCaseMap &responseHeader,const string &filePath, bool use_mmap = true) const;
+    void responseFile(const StrCaseMap &requestHeader,const StrCaseMap &responseHeader,const std::string &filePath, bool use_mmap = true) const;
    operator bool();
 private:
    HttpResponseInvokerLambda0 _lambad;
@@ -46,7 +46,7 @@ private:
 */
 class HttpFileManager  {
 public:
-    typedef function<void(int code, const string &content_type, const StrCaseMap &responseHeader, const HttpBody::Ptr &body)> invoker;
+    typedef std::function<void(int code, const std::string &content_type, const StrCaseMap &responseHeader, const HttpBody::Ptr &body)> invoker;
    /**
     * 访问文件或文件夹
@@ -54,14 +54,14 @@ public:
     * @param parser http请求
     * @param cb 回调对象
    */
-    static void onAccessPath(TcpSession &sender, Parser &parser, const invoker &cb);
+    static void onAccessPath(toolkit::TcpSession &sender, Parser &parser, const invoker &cb);
    /**
     * 获取mime值
     * @param name 文件后缀
     * @return mime值
     */
-    static const string &getContentType(const char *name);
+    static const std::string &getContentType(const char *name);
 private:
    HttpFileManager() = delete;
    ~HttpFileManager() = delete;

--- a/src/Http/HttpRequestSplitter.cpp
+++ b/src/Http/HttpRequestSplitter.cpp
@@ -12,6 +12,7 @@
 #include "Util/logger.h"
 #include "Util/util.h"
 using namespace toolkit;
+using namespace std;
 //协议解析最大缓存1兆数据
 static constexpr size_t kMaxCacheSize = 1 * 1024 * 1024;

--- a/src/Http/HttpRequestSplitter.h
+++ b/src/Http/HttpRequestSplitter.h
@@ -13,8 +13,6 @@
 #include <string>
 #include "Network/Buffer.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit {
@@ -83,7 +81,7 @@ protected:
 private:
    ssize_t _content_len = 0;
    size_t _remain_data_size = 0;
-    BufferLikeString _remain_data;
+    toolkit::BufferLikeString _remain_data;
 };
 } /* namespace mediakit */

--- a/src/Http/HttpRequester.cpp
+++ b/src/Http/HttpRequester.cpp
@@ -10,6 +10,9 @@
 #include "HttpRequester.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 void HttpRequester::onResponseHeader(const string &status, const HttpHeader &headers) {

--- a/src/Http/HttpRequester.h
+++ b/src/Http/HttpRequester.h
@@ -18,22 +18,22 @@ namespace mediakit {
 class HttpRequester : public HttpClientImp {
 public:
    using Ptr = std::shared_ptr<HttpRequester>;
-    using HttpRequesterResult = std::function<void(const SockException &ex, const Parser &response)>;
+    using HttpRequesterResult = std::function<void(const toolkit::SockException &ex, const Parser &response)>;
    HttpRequester() = default;
    ~HttpRequester() override = default;
    void setOnResult(const HttpRequesterResult &onResult);
-    void startRequester(const string &url, const HttpRequesterResult &on_result, float timeout_sec = 10);
+    void startRequester(const std::string &url, const HttpRequesterResult &on_result, float timeout_sec = 10);
    void clear() override;
 private:
-    void onResponseHeader(const string &status, const HttpHeader &headers) override;
+    void onResponseHeader(const std::string &status, const HttpHeader &headers) override;
    void onResponseBody(const char *buf, size_t size) override;
-    void onResponseCompleted(const SockException &ex) override;
+    void onResponseCompleted(const toolkit::SockException &ex) override;
 private:
-    string _res_body;
+    std::string _res_body;
    HttpRequesterResult _on_result;
 };

--- a/src/Http/HttpSession.cpp
+++ b/src/Http/HttpSession.cpp
@@ -17,6 +17,8 @@
 #include "HttpConst.h"
 #include "Util/base64.h"
 #include "Util/SHA1.h"
+using namespace std;
 using namespace toolkit;
 namespace mediakit {
@@ -592,15 +594,20 @@ void HttpSession::sendResponse(int code,
        return;
    }
+    if (typeid(*this) == typeid(HttpSession) && !body->sendFile(getSock()->rawFD())) {
+        //http支持sendfile优化
+        return;
+    }
    GET_CONFIG(uint32_t, sendBufSize, Http::kSendBufSize);
-    if(body->remainSize() > sendBufSize){
+    if (body->remainSize() > sendBufSize) {
        //文件下载提升发送性能
        setSocketFlags();
    }
    //发送http body
-    AsyncSenderData::Ptr data = std::make_shared<AsyncSenderData>(shared_from_this(),body,bClose);
+    AsyncSenderData::Ptr data = std::make_shared<AsyncSenderData>(shared_from_this(), body, bClose);
-    getSock()->setOnFlush([data](){
+    getSock()->setOnFlush([data]() {
        return AsyncSender::onSocketFlushed(data);
    });
    AsyncSender::onSocketFlushed(data);

--- a/src/Http/HttpSession.h
+++ b/src/Http/HttpSession.h
@@ -22,12 +22,9 @@
 #include "TS/TSMediaSource.h"
 #include "FMP4/FMP4MediaSource.h"
-using namespace std;
-using namespace toolkit;
 namespace mediakit {
-class HttpSession: public TcpSession,
+class HttpSession: public toolkit::TcpSession,
                   public FlvMuxer,
                   public HttpRequestSplitter,
                   public WebSocketSplitter {
@@ -40,19 +37,19 @@ public:
     * @param accessPath 运行或禁止访问的根目录
     * @param cookieLifeSecond 鉴权cookie有效期
     **/
-    typedef std::function<void(const string &errMsg,const string &accessPath, int cookieLifeSecond)> HttpAccessPathInvoker;
+    typedef std::function<void(const std::string &errMsg,const std::string &accessPath, int cookieLifeSecond)> HttpAccessPathInvoker;
-    HttpSession(const Socket::Ptr &pSock);
+    HttpSession(const toolkit::Socket::Ptr &pSock);
    ~HttpSession() override;
-    void onRecv(const Buffer::Ptr &) override;
+    void onRecv(const toolkit::Buffer::Ptr &) override;
-    void onError(const SockException &err) override;
+    void onError(const toolkit::SockException &err) override;
    void onManager() override;
-    static string urlDecode(const string &str);
+    static std::string urlDecode(const std::string &str);
 protected:
    //FlvMuxer override
-    void onWrite(const Buffer::Ptr &data, bool flush) override ;
+    void onWrite(const toolkit::Buffer::Ptr &data, bool flush) override ;
    void onDetach() override;
    std::shared_ptr<FlvMuxer> getSharedPtr() override;
@@ -74,7 +71,7 @@ protected:
                                        size_t len,
                                        size_t totalSize,
                                        size_t recvedSize){
-        shutdown(SockException(Err_shutdown,"http post content is too huge,default closed"));
+        shutdown(toolkit::SockException(toolkit::Err_shutdown,"http post content is too huge,default closed"));
    }
    /**
@@ -92,7 +89,7 @@ protected:
     * 发送数据进行websocket协议打包后回调
     * @param buffer websocket协议数据
     */
-    void onWebSocketEncodeData(Buffer::Ptr buffer) override;
+    void onWebSocketEncodeData(toolkit::Buffer::Ptr buffer) override;
    /**
     * 接收到完整的一个webSocket数据包后回调
@@ -107,11 +104,11 @@ private:
    void Handle_Req_HEAD(ssize_t &content_len);
    void Handle_Req_OPTIONS(ssize_t &content_len);
-    bool checkLiveStream(const string &schema, const string  &url_suffix, const function<void(const MediaSource::Ptr &src)> &cb);
+    bool checkLiveStream(const std::string &schema, const std::string  &url_suffix, const std::function<void(const MediaSource::Ptr &src)> &cb);
-    bool checkLiveStreamFlv(const function<void()> &cb = nullptr);
+    bool checkLiveStreamFlv(const std::function<void()> &cb = nullptr);
-    bool checkLiveStreamTS(const function<void()> &cb = nullptr);
+    bool checkLiveStreamTS(const std::function<void()> &cb = nullptr);
-    bool checkLiveStreamFMP4(const function<void()> &fmp4_list = nullptr);
+    bool checkLiveStreamFMP4(const std::function<void()> &fmp4_list = nullptr);
    bool checkWebSocket();
    bool emitHttpEvent(bool doInvoke);
@@ -129,18 +126,17 @@ private:
    bool _live_over_websocket = false;
    //消耗的总流量
    uint64_t _total_bytes_usage = 0;
-    string _origin;
+    std::string _origin;
    Parser _parser;
-    Ticker _ticker;
+    toolkit::Ticker _ticker;
    MediaInfo _mediaInfo;
    TSMediaSource::RingType::RingReader::Ptr _ts_reader;
    FMP4MediaSource::RingType::RingReader::Ptr _fmp4_reader;
    //处理content数据的callback
-    function<bool (const char *data,size_t len) > _contentCallBack;
+    std::function<bool (const char *data,size_t len) > _contentCallBack;
 };
+using HttpsSession = toolkit::TcpSessionWithSSL<HttpSession>;
-typedef TcpSessionWithSSL<HttpSession> HttpsSession;
 } /* namespace mediakit */

--- a/src/Http/HttpTSPlayer.cpp
+++ b/src/Http/HttpTSPlayer.cpp
@@ -10,6 +10,9 @@
 #include "HttpTSPlayer.h"
+using namespace std;
+using namespace toolkit;
 namespace mediakit {
 HttpTSPlayer::HttpTSPlayer(const EventPoller::Ptr &poller, bool split_ts) {

--- a/src/Http/HttpTSPlayer.h
+++ b/src/Http/HttpTSPlayer.h
@@ -15,17 +15,15 @@
 #include "Player/MediaPlayer.h"
 #include "Rtp/TSDecoder.h"
-using namespace toolkit;
 namespace mediakit {
 //http-ts播发器，未实现ts解复用
 class HttpTSPlayer : public HttpClientImp {
 public:
    using Ptr = std::shared_ptr<HttpTSPlayer>;
-    using onComplete = std::function<void(const SockException &)>;
+    using onComplete = std::function<void(const toolkit::SockException &)>;
-    HttpTSPlayer(const EventPoller::Ptr &poller = nullptr, bool split_ts = true);
+    HttpTSPlayer(const toolkit::EventPoller::Ptr &poller = nullptr, bool split_ts = true);
    ~HttpTSPlayer() override = default;
    /**
@@ -40,9 +38,9 @@ public:
 protected:
    ///HttpClient override///
-    void onResponseHeader(const string &status, const HttpHeader &header) override;
+    void onResponseHeader(const std::string &status, const HttpHeader &header) override;
    void onResponseBody(const char *buf, size_t size) override;
-    void onResponseCompleted(const SockException &ex) override;
+    void onResponseCompleted(const toolkit::SockException &ex) override;
 protected:
    /**
@@ -51,7 +49,7 @@ protected:
    virtual void onPacket(const char *data, size_t len);
 private:
-    void emitOnComplete(const SockException &ex);
+    void emitOnComplete(const toolkit::SockException &ex);
 private:
    bool _split_ts;

--- a/src/Http/TsPlayer.cpp
+++ b/src/Http/TsPlayer.cpp
--- a/src/Http/TsPlayer.h
+++ b/src/Http/TsPlayer.h
--- a/src/Http/TsPlayerImp.h
+++ b/src/Http/TsPlayerImp.h
--- a/src/Http/TsplayerImp.cpp
+++ b/src/Http/TsplayerImp.cpp
--- a/src/Http/WebSocketClient.h
+++ b/src/Http/WebSocketClient.h
--- a/src/Http/WebSocketSession.h
+++ b/src/Http/WebSocketSession.h
--- a/src/Http/WebSocketSplitter.cpp
+++ b/src/Http/WebSocketSplitter.cpp
--- a/src/Http/WebSocketSplitter.h
+++ b/src/Http/WebSocketSplitter.h
--- a/src/Http/strCoding.cpp
+++ b/src/Http/strCoding.cpp
--- a/src/Http/strCoding.h
+++ b/src/Http/strCoding.h
--- a/src/Player/MediaPlayer.cpp
+++ b/src/Player/MediaPlayer.cpp
--- a/src/Player/MediaPlayer.h
+++ b/src/Player/MediaPlayer.h
--- a/src/Player/PlayerBase.cpp
+++ b/src/Player/PlayerBase.cpp
--- a/src/Player/PlayerBase.h
+++ b/src/Player/PlayerBase.h
--- a/src/Player/PlayerProxy.cpp
+++ b/src/Player/PlayerProxy.cpp
--- a/src/Player/PlayerProxy.h
+++ b/src/Player/PlayerProxy.h
--- a/src/Pusher/MediaPusher.cpp
+++ b/src/Pusher/MediaPusher.cpp
--- a/src/Pusher/MediaPusher.h
+++ b/src/Pusher/MediaPusher.h
--- a/src/Pusher/PusherBase.cpp
+++ b/src/Pusher/PusherBase.cpp
--- a/src/Pusher/PusherBase.h
+++ b/src/Pusher/PusherBase.h
--- a/src/Pusher/PusherProxy.cpp
+++ b/src/Pusher/PusherProxy.cpp
--- a/src/Pusher/PusherProxy.h
+++ b/src/Pusher/PusherProxy.h
--- a/src/Record/HlsMaker.cpp
+++ b/src/Record/HlsMaker.cpp
--- a/src/Record/HlsMaker.h
+++ b/src/Record/HlsMaker.h
--- a/src/Record/HlsMakerImp.cpp
+++ b/src/Record/HlsMakerImp.cpp
--- a/src/Record/HlsMakerImp.h
+++ b/src/Record/HlsMakerImp.h
--- a/src/Record/HlsMediaSource.cpp
+++ b/src/Record/HlsMediaSource.cpp
--- a/src/Record/HlsMediaSource.h
+++ b/src/Record/HlsMediaSource.h
--- a/src/Record/HlsRecorder.h
+++ b/src/Record/HlsRecorder.h
--- a/src/Record/MP4.cpp
+++ b/src/Record/MP4.cpp
--- a/src/Record/MP4.h
+++ b/src/Record/MP4.h
--- a/src/Record/MP4Demuxer.cpp
+++ b/src/Record/MP4Demuxer.cpp
--- a/src/Record/MP4Demuxer.h
+++ b/src/Record/MP4Demuxer.h
--- a/src/Record/MP4Muxer.cpp
+++ b/src/Record/MP4Muxer.cpp
--- a/src/Record/MP4Muxer.h
+++ b/src/Record/MP4Muxer.h
--- a/src/Record/MP4Reader.cpp
+++ b/src/Record/MP4Reader.cpp
--- a/src/Record/MP4Reader.h
+++ b/src/Record/MP4Reader.h
--- a/src/Record/MP4Recorder.cpp
+++ b/src/Record/MP4Recorder.cpp
--- a/src/Record/MP4Recorder.h
+++ b/src/Record/MP4Recorder.h
--- a/src/Record/MPEG.cpp
+++ b/src/Record/MPEG.cpp
--- a/src/Record/MPEG.h
+++ b/src/Record/MPEG.h
--- a/src/Record/Recorder.cpp
+++ b/src/Record/Recorder.cpp
--- a/src/Record/Recorder.h
+++ b/src/Record/Recorder.h
--- a/src/Rtcp/Rtcp.cpp
+++ b/src/Rtcp/Rtcp.cpp
--- a/src/Rtcp/Rtcp.h
+++ b/src/Rtcp/Rtcp.h
--- a/src/Rtcp/RtcpContext.h
+++ b/src/Rtcp/RtcpContext.h
--- a/src/Rtcp/RtcpFCI.cpp
+++ b/src/Rtcp/RtcpFCI.cpp
--- a/src/Rtcp/RtcpFCI.h
+++ b/src/Rtcp/RtcpFCI.h
--- a/src/Rtmp/FlvMuxer.cpp
+++ b/src/Rtmp/FlvMuxer.cpp
--- a/src/Rtmp/FlvMuxer.h
+++ b/src/Rtmp/FlvMuxer.h
--- a/src/Rtmp/Rtmp.cpp
+++ b/src/Rtmp/Rtmp.cpp
--- a/src/Rtmp/Rtmp.h
+++ b/src/Rtmp/Rtmp.h
--- a/src/Rtmp/RtmpCodec.h
+++ b/src/Rtmp/RtmpCodec.h
--- a/src/Rtmp/RtmpDemuxer.cpp
+++ b/src/Rtmp/RtmpDemuxer.cpp
--- a/src/Rtmp/RtmpDemuxer.h
+++ b/src/Rtmp/RtmpDemuxer.h
--- a/src/Rtmp/RtmpMediaSource.h
+++ b/src/Rtmp/RtmpMediaSource.h
--- a/src/Rtmp/RtmpMediaSourceImp.h
+++ b/src/Rtmp/RtmpMediaSourceImp.h
--- a/src/Rtmp/RtmpMediaSourceMuxer.h
+++ b/src/Rtmp/RtmpMediaSourceMuxer.h
--- a/src/Rtmp/RtmpPlayer.cpp
+++ b/src/Rtmp/RtmpPlayer.cpp
--- a/src/Rtmp/RtmpPlayer.h
+++ b/src/Rtmp/RtmpPlayer.h
--- a/src/Rtmp/RtmpPlayerImp.h
+++ b/src/Rtmp/RtmpPlayerImp.h
--- a/src/Rtmp/RtmpProtocol.cpp
+++ b/src/Rtmp/RtmpProtocol.cpp
--- a/src/Rtmp/RtmpProtocol.h
+++ b/src/Rtmp/RtmpProtocol.h
--- a/src/Rtmp/RtmpPusher.cpp
+++ b/src/Rtmp/RtmpPusher.cpp
--- a/src/Rtmp/RtmpPusher.h
+++ b/src/Rtmp/RtmpPusher.h
--- a/src/Rtmp/RtmpSession.cpp
+++ b/src/Rtmp/RtmpSession.cpp
--- a/src/Rtmp/RtmpSession.h
+++ b/src/Rtmp/RtmpSession.h
--- a/src/Rtmp/amf.cpp
+++ b/src/Rtmp/amf.cpp
--- a/src/Rtmp/amf.h
+++ b/src/Rtmp/amf.h
--- a/src/Rtmp/utils.cpp
+++ b/src/Rtmp/utils.cpp
--- a/src/Rtp/Decoder.cpp
+++ b/src/Rtp/Decoder.cpp
--- a/src/Rtp/Decoder.h
+++ b/src/Rtp/Decoder.h
--- a/src/Rtp/GB28181Process.cpp
+++ b/src/Rtp/GB28181Process.cpp
--- a/src/Rtp/GB28181Process.h
+++ b/src/Rtp/GB28181Process.h
--- a/src/Rtp/PSDecoder.cpp
+++ b/src/Rtp/PSDecoder.cpp
--- a/src/Rtp/PSEncoder.cpp
+++ b/src/Rtp/PSEncoder.cpp
--- a/src/Rtp/PSEncoder.h
+++ b/src/Rtp/PSEncoder.h
--- a/src/Rtp/RtpCache.cpp
+++ b/src/Rtp/RtpCache.cpp
--- a/src/Rtp/RtpCache.h
+++ b/src/Rtp/RtpCache.h
--- a/src/Rtp/RtpProcess.cpp
+++ b/src/Rtp/RtpProcess.cpp
--- a/src/Rtp/RtpProcess.h
+++ b/src/Rtp/RtpProcess.h
--- a/src/Rtp/RtpSelector.cpp
+++ b/src/Rtp/RtpSelector.cpp
--- a/src/Rtp/RtpSelector.h
+++ b/src/Rtp/RtpSelector.h
--- a/src/Rtp/RtpSender.cpp
+++ b/src/Rtp/RtpSender.cpp
--- a/src/Rtp/RtpSender.h
+++ b/src/Rtp/RtpSender.h
--- a/src/Rtp/RtpServer.cpp
+++ b/src/Rtp/RtpServer.cpp
--- a/src/Rtp/RtpServer.h
+++ b/src/Rtp/RtpServer.h
--- a/src/Rtp/RtpSession.cpp
+++ b/src/Rtp/RtpSession.cpp
--- a/src/Rtp/RtpSession.h
+++ b/src/Rtp/RtpSession.h
--- a/src/Rtp/TSDecoder.h
+++ b/src/Rtp/TSDecoder.h
--- a/src/Rtsp/RtpCodec.h
+++ b/src/Rtsp/RtpCodec.h
--- a/src/Rtsp/RtpMultiCaster.h
+++ b/src/Rtsp/RtpMultiCaster.h
--- a/src/Rtsp/RtpReceiver.h
+++ b/src/Rtsp/RtpReceiver.h
--- a/src/Rtsp/Rtsp.cpp
+++ b/src/Rtsp/Rtsp.cpp
--- a/src/Rtsp/Rtsp.h
+++ b/src/Rtsp/Rtsp.h
--- a/src/Rtsp/RtspDemuxer.h
+++ b/src/Rtsp/RtspDemuxer.h
--- a/src/Rtsp/RtspMediaSource.h
+++ b/src/Rtsp/RtspMediaSource.h
--- a/src/Rtsp/RtspMediaSourceImp.h
+++ b/src/Rtsp/RtspMediaSourceImp.h
--- a/src/Rtsp/RtspMediaSourceMuxer.h
+++ b/src/Rtsp/RtspMediaSourceMuxer.h
--- a/src/Rtsp/RtspMuxer.cpp
+++ b/src/Rtsp/RtspMuxer.cpp
--- a/src/Rtsp/RtspMuxer.h
+++ b/src/Rtsp/RtspMuxer.h
--- a/src/Rtsp/RtspPlayer.cpp
+++ b/src/Rtsp/RtspPlayer.cpp
--- a/src/Rtsp/RtspPlayer.h
+++ b/src/Rtsp/RtspPlayer.h
--- a/src/Rtsp/RtspPlayerImp.h
+++ b/src/Rtsp/RtspPlayerImp.h
--- a/src/Rtsp/RtspPusher.cpp
+++ b/src/Rtsp/RtspPusher.cpp
--- a/src/Rtsp/RtspPusher.h
+++ b/src/Rtsp/RtspPusher.h
--- a/src/Rtsp/RtspSession.h
+++ b/src/Rtsp/RtspSession.h
--- a/src/Rtsp/RtspSplitter.cpp
+++ b/src/Rtsp/RtspSplitter.cpp
--- a/src/Rtsp/UDPServer.cpp
+++ b/src/Rtsp/UDPServer.cpp
--- a/src/Rtsp/UDPServer.h
+++ b/src/Rtsp/UDPServer.h
--- a/src/Shell/ShellCMD.h
+++ b/src/Shell/ShellCMD.h
--- a/src/Shell/ShellSession.cpp
+++ b/src/Shell/ShellSession.cpp
--- a/src/Shell/ShellSession.h
+++ b/src/Shell/ShellSession.h
--- a/src/TS/TSMediaSource.h
+++ b/src/TS/TSMediaSource.h
--- a/src/TS/TSMediaSourceMuxer.h
+++ b/src/TS/TSMediaSourceMuxer.h
--- a/tests/tab.cpp
+++ b/tests/tab.cpp
--- a/tests/test_bench_proxy.cpp
+++ b/tests/test_bench_proxy.cpp
--- a/tests/test_bench_pull.cpp
+++ b/tests/test_bench_pull.cpp
--- a/tests/test_bench_push.cpp
+++ b/tests/test_bench_push.cpp
--- a/tests/test_server.cpp
+++ b/tests/test_server.cpp
--- a/tests/test_sortor.cpp
+++ b/tests/test_sortor.cpp
--- a/tests/test_wsClient.cpp
+++ b/tests/test_wsClient.cpp
--- a/tests/test_wsServer.cpp
+++ b/tests/test_wsServer.cpp
--- a/webrtc/DtlsTransport.cpp
+++ b/webrtc/DtlsTransport.cpp
--- a/webrtc/Nack.cpp
+++ b/webrtc/Nack.cpp
--- a/webrtc/Nack.h
+++ b/webrtc/Nack.h
--- a/webrtc/RtpExt.cpp
+++ b/webrtc/RtpExt.cpp
--- a/webrtc/RtpExt.h
+++ b/webrtc/RtpExt.h
--- a/webrtc/Sdp.cpp
+++ b/webrtc/Sdp.cpp
--- a/webrtc/Sdp.h
+++ b/webrtc/Sdp.h
--- a/webrtc/SrtpSession.cpp
+++ b/webrtc/SrtpSession.cpp
--- a/webrtc/TwccContext.h
+++ b/webrtc/TwccContext.h
--- a/webrtc/WebRtcEchoTest.h
+++ b/webrtc/WebRtcEchoTest.h
--- a/webrtc/WebRtcPlayer.cpp
+++ b/webrtc/WebRtcPlayer.cpp
--- a/webrtc/WebRtcPlayer.h
+++ b/webrtc/WebRtcPlayer.h
--- a/webrtc/WebRtcPusher.cpp
+++ b/webrtc/WebRtcPusher.cpp
--- a/webrtc/WebRtcPusher.h
+++ b/webrtc/WebRtcPusher.h
--- a/webrtc/WebRtcSession.cpp
+++ b/webrtc/WebRtcSession.cpp
--- a/webrtc/WebRtcSession.h
+++ b/webrtc/WebRtcSession.h
--- a/webrtc/WebRtcTransport.cpp
+++ b/webrtc/WebRtcTransport.cpp
--- a/webrtc/WebRtcTransport.h
+++ b/webrtc/WebRtcTransport.h
--- a/webrtc/logger.h
+++ b/webrtc/logger.h