新闻中心

Mirth Connect:区分自动与手动通道轮询以实现条件性目的地执行

2025-12-03
浏览次数:
返回列表

Mirth Connect:区分自动与手动通道轮询以实现条件性目的地执行

本教程详细介绍了如何在mirth connect通道中区分自动(计划性)轮询和手动(部署时)轮询。通过在部署脚本中设置一个全局通道变量,并在源过滤器/转换器中检查该变量,可以有效地识别轮询类型。这使得开发者能够根据轮询来源,灵活地控制目的地(destination)的执行逻辑,从而实现更精细的通道行为管理。

理解通道轮询的场景与挑战

在Mirth Connect中,通道的源连接器(Source Connector)通常配置为周期性地轮询外部资源(如文件系统、数据库等)以获取消息。轮询可以分为两种主要类型:

  1. 自动(计划性)轮询:根据Cron表达式或预设间隔自动执行,通常用于夜间备份、定时同步等场景。
  2. 手动轮询
    • 部署时轮询:当通道部署或重新部署时,如果勾选了“Poll Once on Start”选项,会立即执行一次轮询。这常被视为一种初始的手动触发。
    • 按需轮询:用户通过Mirth Connect仪表板手动点击“Poll Now”按钮触发的轮询。

开发人员有时需要根据轮询的类型来执行不同的业务逻辑。例如,一个通道可能需要在夜间自动备份文件,而在手动触发时执行文件恢复操作。直接从源过滤器或转换器中获取当前轮询是自动还是手动的状态,Mirth Connect并没有提供一个直接的API或内置变量。

利用全局通道变量区分轮询类型

为了解决上述挑战,我们可以利用Mirth Connect的全局通道变量(globalChannelMap)机制,结合通道的部署脚本和源处理脚本来实现轮询类型的区分。核心思路是:在通道部署时设置一个标志,然后在每次轮询时检查并根据该标志判断是否为“部署时轮询”。

步骤一:在部署脚本中初始化标志

当通道部署或重新部署时,Mirth Connect会执行通道的部署脚本(Deploy Script)。我们可以在这里设置一个全局通道变量作为“新部署”的标志。

  1. 打开你的Mirth Connect 通道配置。

  2. 导航到“Scripts”选项卡。

  3. 在“Deploy Script”区域中添加以下代码:

    // 设置一个全局通道变量,标记通道刚刚部署
    globalChannelMap.put('NEW_DEPLOY', true);
    return;

    这段代码的目的是在通道每次部署时,将NEW_DEPLOY这个键的值设置为true并存储在当前通道的全局映射中。这意味着通道在刚刚部署后,NEW_DEPLOY标志将为真。

步骤二:在源过滤器/转换器中检测轮询类型

在源连接器的过滤器或转换器脚本中(例如,在“Source Transformer”或“Source Filter”中),我们可以在每次消息处理前检查NEW_DEPLOY变量的值。

  1. 导航到“Source”选项卡。

    Remover Remover

    几秒钟去除图中不需要的元素

    Remover 304 查看详情 Remover
  2. 选择“Transformer”或“Filter”子选项卡。

  3. 在相应的脚本区域中添加以下代码:

    if ($gc('NEW_DEPLOY') == true) {
        // 记录日志,表明这是一个部署时轮询
        logger.info("NEW_DEPLOY WAS " + $gc('NEW_DEPLOY') + ", 这次轮询发生在部署之后 (Poll On Deploy)");
        // 重置标志,以便后续的轮询被识别为计划性轮询
        globalChannelMap.put('NEW_DEPLOY', false);
        // 在这里可以添加针对“部署时轮询”的特定逻辑
        // 例如,设置一个变量来控制目的地执行
        channelMap.put('pollType', 'DEPLOY_POLL');
    } else {
        // 记录日志,表明这是一个计划性轮询
        logger.info("NEW_DEPLOY WAS " + $gc('NEW_DEPLOY') + ", 这次轮询是计划性的");
        // 在这里可以添加针对“计划性轮询”的特定逻辑
        channelMap.put('pollType', 'SCHEDULED_POLL');
    }

    这段脚本首先检查NEW_DEPLOY变量。如果为true,则表明这是通道部署后的第一次轮询(通常对应“Poll Once on Start”)。脚本会记录日志,然后将NEW_DEPLOY重置为false,确保后续的轮询不会再次被误判为部署时轮询。同时,我们将轮询类型存储在channelMap中,方便后续的目的地使用。

步骤三:根据轮询类型控制目的地执行

在目的地的过滤器或转换器中,你可以通过检查channelMap.get('pollType')的值来决定是否执行该目的地。

例如,如果你有一个用于恢复文件的目的地,你可能只希望在DEPLOY_POLL时执行它:

在目的地过滤器中:

// 只有当轮询类型是部署时轮询时才通过过滤器
if (channelMap.get('pollType') == 'DEPLOY_POLL') {
    return true; // 允许消息通过,执行此目的地
}
return false; // 阻止消息通过,不执行此目的地

或者,你可以在源转换器中动态地移除不需要的目的地:

// 在源转换器中,根据 pollType 移除不需要的目的地
if (channelMap.get('pollType') == 'SCHEDULED_POLL') {
    // 假设 'RestoreDestination' 是恢复文件的目的地名称
    destinationSet.remove('RestoreDestination');
}

注意事项与局限性

  • “Poll Once on Start”的关联:此方法主要用于区分通道部署后的第一次轮询(通常与“Poll Once on Start”选项相关)和后续的计划性轮询。
  • 手动“Poll Now”的识别:如果用户在通道部署后,通过Mirth Connect仪表板手动点击“Poll Now”按钮触发轮询,此方法将无法将其与计划性轮询区分开来,因为NEW_DEPLOY标志已经被重置为false。如果需要区分所有类型的手动触发,可能需要更复杂的机制(例如,结合外部API调用或更高级的Mirth Connect事件监听)。
  • 通道重部署:每次通道重新部署时,NEW_DEPLOY标志都会被重置为true,因此部署后的第一次轮询将再次被识别为“部署时轮询”。
  • 日志记录:在脚本中使用logger.info()可以有效地在Mirth Connect服务器日志中查看轮询类型,这对于调试和监控非常有帮助。
  • 变量作用域:globalChannelMap变量在通道的生命周期内持续存在,而channelMap变量则针对每条消息的生命周期。根据你的需求选择合适的变量作用域。

总结

通过在Mirth Connect的部署脚本和源处理脚本中巧妙地利用全局通道变量,我们可以有效地识别通道部署后的首次轮询与后续的计划性轮询。这种方法提供了一种灵活的机制,使得开发者能够根据轮询的来源,精确地控制不同目的地的执行行为,从而更好地满足复杂的业务逻辑需求。虽然对于所有类型的“手动”轮询识别存在一定局限性,但对于区分部署时的初始化操作和常规的自动化流程,该方案非常实用且易于实现。

以上就是Mirth Connect:区分自动与手动通道轮询以实现条件性目的地执行的详细内容,更多请关注其它相关文章!


# 这段  # 关键词挖掘排名  # 驻马店网站推广营销公司  # 丽江古城营销推广方案  # 淘宝排名关键词有哪些  # 天河seo优化营销推广  # 台州标题seo优化  # 招商加盟论坛推广营销  # 美术展营销推广案例  # 河北进口网站建设调试  # 推广模式营销怎么写  # 这是一个  # 作用域  # 你可以  # 选项卡  # 有效地  # 我们可以  # 不需要  # 在这里  # 仪表板  # 器中  # red  # api调用 


相关栏目: 【 科技资讯46185 】 【 网络学院92790


相关推荐: 深入理解Promise链:如何在catch后中断then的执行  Composer的 archive 命令怎么用_快速打包你的PHP项目及其Composer依赖  Pygame教程:解决用户输入与游戏状态更新不同步问题  TikTok搜索不到用户发布内容怎么办 TikTok用户内容搜索优化方法  HTML长属性值处理:表单action路径优化与代码规范应对  CSS如何设置hover状态颜色_hover伪类调整背景或文字颜色  Python异步编程实践:使用Binance API构建实时交易数据流  哔哩哔哩忘记密码了怎么找回_哔哩哔哩密码找回方法  12306选座怎么选到特殊座位_12306特殊座位选择注意事项  J*aScript中localStorage数据的获取、清洗与格式化教程  c++中的std::forward_list和std::list有什么不同_c++ forward_list与list区别分析  Go语言HTML解析:利用Goquery精准获取指定元素内容  j*a toString()的覆盖  sublime如何只显示或隐藏特定类型文件_sublime侧边栏文件过滤  大麦的“候补”是什么意思 大麦候补购票规则【详解】  windows10怎么查看本机ip_windows10命令提示符ipconfig使用  深入理解Go语言中Map值与方法接收器的交互:为什么需要临时变量  处理Kafka消费者会话超时:深入理解消息处理语义与幂等性  b站怎么看视频的弹幕数量_b站弹幕数量查看方法  Lar*el表单中优雅地处理“返回”按钮以规避验证:最佳实践指南  c++如何使用Catch2编写单元测试_c++简洁易用的BDD风格测试框架  c++中的std::launder有什么实际用途_c++对象生命周期与指针优化  QQ邮箱网页版快速登录 QQ邮箱邮箱账号官方入口地址  如何使用纯J*aScript判断Input元素是否在特定类容器内  漫蛙2正版漫画站 漫蛙2网页版快速访问入口  包子漫画官方网站阅读入口-包子漫画在线漫画官网直达链接  2026年发布! 美少女养成动作RPG《神剑少女战记》发布实机演示  windows10怎么关闭系统提示音_windows10彻底静音设置方法  QQ邮箱官方网页版登录 QQ邮箱个人邮箱快速访问  天猫2025双十一0点秒杀攻略 天猫爆款抢购时间  电脑屏幕颜色不舒服怎么办_Windows夜间模式与色彩校准教程【护眼技巧】  LINUX的I/O重定向是什么_深入理解LINUX中 >、>> 与 < 的区别  在Typer应用中优雅地处理和重组任意命令行参数  Vue.js 图片显示异常排查:理解应用挂载范围与DOM ID唯一性  在J*a里如何理解依赖关系的方向_依赖方向在模块结构中的作用  在FastAPI中利用lifespan与依赖注入高效管理Redis连接池  win11 arm版怎么安装 M1/M2 Mac虚拟机安装ARM win11的方法  顺丰快递查单号物流信息 顺丰快递小程序查询入口  Golang并发任务中错误如何聚合_Golang goroutine error收集方式  Excel如何用迷你图显趋势_Excel用迷你图显趋势【趋势小图】  解决Tabulator日期时间排序问题的专业指南  iCloud登录入口网页版 苹果iCloud官网登录  抖音怎么赚钱_抖音创作者变现方法与途径指南  cad如何更改注释性对象的比例_cad注释性比例调整方法  怎么去除衣服上的口红印_生活小妙招教你用酒精轻松擦除  JUnit5/Mockito:优雅测试内部依赖与异常处理的实践  护手霜蹭到袖口上了如何清洗? 怎样避免留下一圈油印?  vivo浏览器自带的下载器速度慢怎么办 vivo浏览器提升文件下载速度的技巧  Win10快速启动功能利弊分析 Win10开启或关闭快速启动教程【技巧】  在Qt QML中通过Python字典动态更新TextEdit内容的教程 

搜索