如何每日重启Tibco EMS订阅会话以确保其持续活跃？

针对你的问题，要实现每日自动重启Tibco EMS订阅会话，核心是在代码层面封装可复用的订阅逻辑，并添加定时触发机制，同时确保旧资源被正确释放避免泄漏。以下是具体实现方案：

1. 封装可复用的订阅/重连逻辑 #

首先将原有的订阅代码抽成独立方法，同时添加旧连接资源的清理逻辑：

private TopicConnection _conn;
private TopicSession _session;
private TopicSubscriber _ts;
private readonly string _url;
private readonly string _username;
private readonly string _password;
private readonly string _topicName;

// 构造函数注入配置参数
public YourSubscriberService(string url, string username, string password, string topicName)
{
    _url = url;
    _username = username;
    _password = password;
    _topicName = topicName;
}

public void ReconnectAndSubscribe()
{
    // 先清理旧资源
    CleanupExistingResources();

    // 重新创建订阅会话
    try
    {
        TopicConnectionFactory factory = new TopicConnectionFactory(_url);
        _conn = factory.CreateTopicConnection(_username, _password);
        _conn.Start();
        
        _session = _conn.CreateTopicSession(false, Session.AUTO_ACKNOWLEDGE);
        Topic clientTopic = _session.CreateTopic(_topicName);
        
        _ts = _session.CreateSubscriber(clientTopic, null, true);
        _ts.MessageHandler += new EMSMessageHandler(Event_MessageHandler);
    }
    catch (EMSException ex)
    {
        // 处理连接异常，比如日志记录、重试逻辑
        Console.WriteLine($"订阅重连失败: {ex.Message}");
        // 可选：添加重试机制，比如间隔一段时间后再次尝试
    }
}

private void CleanupExistingResources()
{
    if (_ts != null)
    {
        _ts.MessageHandler -= Event_MessageHandler;
        try { _ts.Close(); } catch { /* 忽略关闭异常 */ }
        _ts = null;
    }
    
    if (_session != null)
    {
        try { _session.Close(); } catch { /* 忽略关闭异常 */ }
        _session = null;
    }
    
    if (_conn != null)
    {
        try { _conn.Close(); } catch { /* 忽略关闭异常 */ }
        _conn = null;
    }
}

2. 添加每日定时触发机制 #

根据你的.NET应用类型，选择合适的定时方案：

方案A：使用System.Timers.Timer（适合控制台或简单服务） #

在服务启动时初始化定时器，设置每日触发一次：

public void StartDailyRestartTimer()
{
    // 计算距离下一次每日触发的时间（比如每天凌晨2点）
    var now = DateTime.Now;
    var targetTime = new DateTime(now.Year, now.Month, now.Day, 2, 0, 0);
    if (now > targetTime)
    {
        targetTime = targetTime.AddDays(1);
    }
    var initialDelay = (targetTime - now).TotalMilliseconds;

    var timer = new System.Timers.Timer();
    timer.Interval = 24 * 60 * 60 * 1000; // 24小时间隔
    timer.AutoReset = true;
    timer.Elapsed += (sender, e) => ReconnectAndSubscribe();
    timer.Start();
    
    // 立即触发一次初始订阅，同时设置首次延迟到目标时间
    ReconnectAndSubscribe();
    timer.Interval = 24 * 60 * 60 * 1000;
}

方案B：使用IHostedService（适合ASP.NET Core应用） #

如果是ASP.NET Core服务，推荐用托管服务实现定时任务：

public class DailySubscriptionRestartService : IHostedService, IDisposable
{
    private Timer _timer;
    private readonly YourSubscriberService _subscriberService;

    public DailySubscriptionRestartService(YourSubscriberService subscriberService)
    {
        _subscriberService = subscriberService;
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        // 计算首次触发延迟
        var now = DateTime.Now;
        var targetTime = new DateTime(now.Year, now.Month, now.Day, 2, 0, 0);
        if (now > targetTime)
        {
            targetTime = targetTime.AddDays(1);
        }
        var initialDelay = (targetTime - now).TotalMilliseconds;

        _timer = new Timer(DoWork, null, (int)initialDelay, 24 * 60 * 60 * 1000);
        return Task.CompletedTask;
    }

    private void DoWork(object state)
    {
        _subscriberService.ReconnectAndSubscribe();
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        _timer?.Change(Timeout.Infinite, 0);
        return Task.CompletedTask;
    }

    public void Dispose()
    {
        _timer?.Dispose();
    }
}

然后在Startup.cs或Program.cs中注册服务：

builder.Services.AddHostedService<DailySubscriptionRestartService>();
builder.Services.AddSingleton<YourSubscriberService>(sp => 
    new YourSubscriberService(
        builder.Configuration["Tibco:Url"],
        builder.Configuration["Tibco:Username"],
        builder.Configuration["Tibco:Password"],
        builder.Configuration["Tibco:TopicName"]
    )
);

3. 额外注意事项 #

• 异常处理：在重连逻辑中添加日志记录，便于排查订阅失败原因；可添加重试机制，避免单次失败导致订阅中断。
• 资源清理：必须确保旧的TopicSubscriber、TopicSession和TopicConnection被正确关闭，否则会导致Tibco EMS服务器端资源泄漏。
• 时间配置：可将每日重启时间配置到环境变量中（比如OpenShift的ConfigMap），方便灵活调整。

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