C++热加载

假设一种环境,我们要对服务热拔插一个动态库(.so文件),所要考虑的是多线程环境的兼容,不会因为动态库替换后造成栈损毁而崩溃。

这边想到的方法就是封装一个dlopen过程作为对象实例加载(见load_so.h),当发出更新动态库时重新dlopen过程,替换原先的实例,注意这个替换过程必须是温和的、无逢的,这边我们使用智能指针实现。

具体更新的实现通过一个单例(见do_sth.h),调用Reload重新加载动态库。

我们构造一个极简单的动态库测试:

make_so.h

#include "say.h"extern "C"{    void Enter(const std::string &str)    {        Say::instance().Sth(str);   //在这里动态库又过来调用了主程序的单件    }}

say.h 打印消息,这边只是声明一

#include "singleton.h"class Say : public Singleton <Say>{    public:        void Sth(const std::string &str);};



通过编译生test.so:

g++ make_so.cpp -fPIC -shared -pthread -rdynamic -lboost_thread -lboost_system -o test.so -L[boost库目录]

主程序 test.cpp ,用来测试这个动态库test.so





#include <boost/thread.hpp>#include "load_so.h"#include "say.h"class DoSth : public Singleton{    public:        DoSth():m_so(new LoadSo("./test.so"))        {        }        DynamicSo_ptr Get()        {            boost::mutex::scoped_lock lock(m_mtx);            return m_so;        }        void Reload()        {            boost::mutex::scoped_lock lock(m_mtx);            m_so.reset(new LoadSo("./test.so"));        }    private:        DynamicSo_ptr m_so;        boost::mutex m_mtx;};/// Sayvoid Say::Sth(const std::string &str){    std::cout << str << std::endl;}////////////////////////// 测试代码 ////////////////////////////////////////更新动态库void test(){    for(int i=0;i<100;++i)    {        sleep(1);        DoSth::instance().Reload();    }}//运行动态库void test2(){    for(int i=0;irun("12");    }}int main(){    std::cout << "run\n";    boost::thread thread1(&test2);    boost::thread thread2(&test);    thread1.join();    thread2.join();    return 0;}





编译主程序:

g++ -Wall test.cpp -o test -pipe -pthread -ldl -Wl,--export-dynamic -lboost_system -lboost_thread -L[boost库目录]

这边一定要加“-Wl,--export-dynamic”以便导出主程序的符号供动态库回调。

编译成功后生成 test 可执行文件,运行:

#./test

run

12

12

12

12

....

假设这时我们修改 make_so.h



#include "say.h"extern "C"{    void Enter(const std::string &str)    {        Say::instance().Sth(str + ",ab"); //修改输出    }}

g++ make_so.cpp -fPIC -shared -pthread -rdynamic -lboost_thread -lboost_system -o test.so -L[boost库目录]

重新编译后,这时我们主程序会马上响应,输出:

12,ab

12,ab

12,ab

12,ab

....

说明热替换是成功的。

在实际运用中,当要替换动态库时可以在程序中使用

DoSth::instance().Reload();

具体方法很多,可以通过socket、中断信号、监听文件系统、定时更新等方式。

load_so.h 代码:





#ifndef LOAD_SO_H#define LOAD_SO_H#include <iostream>#include <boost/shared_ptr.hpp>#include <dlfcn.h>using namespace std;class LoadSo{    typedef void (*Func)(const std::string &suid);    public:    LoadSo(const char * so_file)    {        load(so_file);    }    ~LoadSo()    {        Close();    }    void Close()    {        dlclose(m_handle);    }    void run( const std::string &str )    {        m_func(str);    }        private:    bool load(const char * so_file)    {        m_handle = dlopen(so_file, RTLD_LAZY);        if (!m_handle)         {            std::string error("Cannot open library: ");            throw std::runtime_error(error + dlerror());            return false;        }        dlerror();        m_func = (Func) dlsym(m_handle, "Enter");        const char *dlsym_error = dlerror();        if (dlsym_error)         {            dlclose(m_handle);            std::string error("Cannot load symbol: ");            throw std::runtime_error(error + dlsym_error);            return false;        }        return true;    }    Func m_func;    void* m_handle;};typedef boost::shared_ptr DynamicSo_ptr;#endif



说在最后,我在一些测试中发现有时并不自动切换到新的动态库的情况,另一个做法就是备用两个动态库,那么在Reload时在两个so文件之间切换,这样可以确保更新,额外给自己找的好处是可以保留旧版本的so。

http://lajabs.net

原文链接: https://www.cnblogs.com/lajabs/archive/2011/07/19/2110408.html

欢迎关注

微信关注下方公众号,第一时间获取干货硬货;公众号内回复【pdf】免费获取数百本计算机经典书籍

原创文章受到原创版权保护。转载请注明出处:https://www.ccppcoding.com/archives/28954

非原创文章文中已经注明原地址,如有侵权,联系删除

关注公众号【高性能架构探索】,第一时间获取最新文章

转载文章受原作者版权保护。转载请注明原作者出处!

(0)
上一篇 2023年2月8日 上午6:22
下一篇 2023年2月8日 上午6:22

相关推荐