如何正确终止运行open62541 OPCUA服务器的线程以实现正常关闭与清理

我开发了一个C语言应用，核心功能包括：

• 从OPCUA服务器轮询数据并广播至Kafka
• 基于open62541库搭建轻量OPCUA服务器，向其他OPCUA客户端开放部分数据点

为避免主线程负载过重，将OPCUA服务器运行在pthread线程中，核心代码如下：

void* startServer(void *vargp)
{
    UA_StatusCode retval = UA_Server_runUntilInterrupt(server);

    return NULL;
}

static void runServer()
{
    int res = setupServer(serverParameters, serverInfos, serverInfosLength);

    ...

    pthread_create(&thread_id, NULL, startServer, NULL);
}

当前遇到的问题：

• 中断信号（SIGINT/SIGTERM）仅送达主线程，OPCUA客户端与Kafka生产者可正常终止清理，但OPCUA服务器无法响应这些信号
• 尝试用pthread_kill(thread_id, SIGTERM);终止服务器线程，清理时仍报错服务器未停止

核心思路：用open62541原生API停止服务器，而非线程信号 #

UA_Server_runUntilInterrupt本质是阻塞等待信号或服务器停止指令，但服务器运行在子线程时，系统信号只会发送到主线程，子线程无法捕获。直接给子线程发信号会破坏open62541的内部状态，导致清理失败。正确做法是调用open62541的停止API触发优雅退出：

1. 主线程注册信号处理函数
   在主线程初始化时注册SIGINT/SIGTERM的处理函数，不要在子线程中处理信号：

#include <signal.h>
#include <pthread.h>

volatile sig_atomic_t g_exit_flag = 0;
UA_Server *g_server; // 确保服务器实例可被主线程访问
pthread_t g_server_thread_id;

void signalHandler(int signum) {
    g_exit_flag = 1;
}

2. 修改服务器线程逻辑
   放弃依赖UA_Server_runUntilInterrupt的信号处理，改用UA_Server_run_iterate实现循环，配合服务器内置的停止标志：

void* startServer(void *vargp)
{
    UA_Server *server = (UA_Server*)vargp;
    while(!UA_Server_getShouldStop(server)) {
        UA_Server_run_iterate(server, 1000); // 1000ms超时，可根据需求调整
    }
    return NULL;
}

static void runServer()
{
    // 初始化服务器...
    g_server = server; // 赋值给全局变量或通过参数传递
    pthread_create(&g_server_thread_id, NULL, startServer, (void*)g_server);
}

3. 主线程触发服务器停止并等待退出
   主线程检测到退出标志后，先清理Kafka生产者和OPCUA客户端，再调用UA_Server_stop触发服务器停止，最后等待线程退出并清理服务器：

int main() {
    // 注册信号处理
    signal(SIGINT, signalHandler);
    signal(SIGTERM, signalHandler);

    // 初始化Kafka生产者、OPCUA客户端、启动自定义OPCUA服务器
    runServer();

    // 主线程主循环（处理轮询OPCUA、发送Kafka等逻辑）
    while(!g_exit_flag) {
        ...
    }

    // 开始清理流程
    // 1. 清理Kafka生产者和OPCUA客户端
    cleanupKafkaProducer();
    cleanupOpcuaClient();

    // 2. 停止OPCUA服务器
    UA_Server_stop(g_server);

    // 3. 等待服务器线程退出
    pthread_join(g_server_thread_id, NULL);

    // 4. 销毁OPCUA服务器实例
    UA_Server_delete(g_server);

    return 0;
}

为什么pthread_kill不行？ #

pthread_kill会给子线程发送信号，但open62541的内部资源（如网络连接、定时器）未被正确释放，服务器仍处于运行状态，后续清理时就会触发报错。

• 避免全局变量：将服务器实例、线程ID、退出标志封装到一个结构体中，通过pthread_create的参数传递给子线程，减少全局变量带来的线程安全风险。
• 简化信号处理：信号处理函数仅设置退出标志，不要执行复杂API调用（部分API在信号上下文可能不安全），由主线程在正常上下文处理停止逻辑。
• 解耦服务器生命周期：将服务器的初始化、启动、停止、清理拆分为独立函数，便于维护和错误处理。
• 增加状态监控：通过UA_Server_getStateAPI监控服务器状态，确保停止流程执行完成后再进行清理。
• 确认线程安全：所有对服务器实例的操作（如UA_Server_stop）需符合open62541的线程安全要求（官方文档显示大部分API是线程安全的）。

内容的提问来源于stack exchange，提问作者Sebastian