MassTransit 是否支持基于 HTTP 传输的 MSMQ?

2024-04-18

HTTP 传输自 MSMQ 3.0 起就可用,但恐怕 MassTransit 不提供使用 HTTP 协议作为队列之间的传输协议的功能。

关于这个有一个非常相似的问题here https://stackoverflow.com/questions/3602422/do-masstransit-or-nservicebus-support-msmq-over-http-transport,尚未得到完全解答。

有谁知道客户端是否可以订阅总线并通过 HTTP 发送/接收消息?这是我愿意实现的架构:

我将在本地网络中拥有 2 台计算机

  • 电脑A运行服务器应用程序和 MassTransit.RuntimeServices
  • 计算机B运行一个向 A 发送消息的客户端应用程序

我希望他们之间的通信通过http 完成。

我尝试更改地址UseSubscriptionService to http代替msmq,但它不起作用。如果我设置电脑的AMSMQ 服务为强化模式,客户端应用程序运行在计算机B尝试订阅时超时mt_subscriptions.

Bus.Initialize(sbc =>
            {
                sbc.UseMsmq();
                sbc.VerifyMsmqConfiguration();
                sbc.UseMulticastSubscriptionClient();
                sbc.ReceiveFrom("msmq://localhost/test_queue_client");
                sbc.UseSubscriptionService("msmq://m3-dev1/mt_subscriptions"); // maybe I could use http instead of msmq, but it doesn't work
            });

有什么线索吗?


不,MassTransit 不支持 MSMQ 的 HTTP。理论上,您可以添加自己的支持该功能的传输。 RabbitMQ 在各方面都是比 MSMQ 更好的传输方式,除非您需要注册分布式事务。 RabbitMQ 只需要在盒子之间打开一个端口。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

MassTransit 是否支持基于 HTTP 传输的 MSMQ? 的相关文章

随机推荐

  • 如何获取当年的总周数?

    我在 stackoverflow 上得到了下面的代码 它返回当年的总周数 但它是硬编码的 在 2014 年和 2016 年不起作用 我如何动态获取当年的总周数 Calendar cal Calendar getInstance cal se
  • Javascript Google Maps API 和非被动事件处理程序

    最近 Chrome 开始发出以下警告 违规 向滚动阻塞 touchmove 事件添加了非被动事件侦听器 考虑将事件处理程序标记为 被动 以使页面响应更快 看https www chromestatus com feature 5745543
  • 当应用程序在 Firebase 后台运行时如何处理通知

    这是我的清单
  • has_many 与总活跃记录

    class Product lt ActiveRecord Base belongs to category has many order items dependent destroy end class OrderItem lt Act
  • 以编程方式嵌入 Java h2 数据库

    目前我们使用HSQLDB http www hsqldb org 作为嵌入式数据库 但随着数据量的增长 我们会寻找内存占用更少的数据库 德比 JavaDB http developers sun com javadb 目前不是一个选项 因为
  • 如何从年、月、日获取日期对象?

    当我使用以下代码时 Date对象错误 Date date new Date day getYear day getMonth day getDay 谁能告诉我如何从年 月 日的值中获取日期对象 您可以使用Calendar类来实现这一点 pu
  • 宏 $(VCTargetsPath) 到底在哪里定义的?

    我们之前有过讨论 https social msdn microsoft com Forums vstudio en US e04e7791 c0c4 4598 b900 310878f5af45 how can i locate and
  • 我们可以更新 Amazon S3 中特定文件的内容吗?

    我正在使用AWS PHP SDK 我将 JSON 文件上传到 S3 存储桶 现在我想获取文件内容 上传到S3存储桶 向抓取的文件内容添加一些附加文本并通过 S3 存储桶更新该文件 我想要的是这样的 文件名 userlist json 使用
  • wagtail 中的嵌套类别/InlinePanel

    我很难实现 嵌套类别 之类的东西 PageA Cat1 SubCat1 SubCat2 Cat2 SubCat1 所有类别和子类别都应可由编辑排序和编辑 我的猜测是这样的 class CategoryTestPage Page conten
  • lucene:如何添加不重复的文档

    就我而言 插入 lucene 索引的每个文档都有其唯一的 ID 当向lucene索引添加新文档时 如果该文档已经存在于索引中 则不应将该文档插入到索引中 如何实施这一战略 我想我应该先用docId搜索文档 如果lucene找不到该文档 那么
  • 如何在 Android 上对 XML 进行编码?

    我需要将 XML 文档编码为一种格式 该格式将作为字符串 即条带标签 通过 XML 解析器 然后我需要再次解码它 并且我需要在 Android 上执行此操作 我正在寻找的 Android API 中的库 类是什么 Thanks XmlSer
  • 运行我的应用程序时,Java 运行时环境检测到致命错误

    我在运行程序时遇到以下错误 并且无法弄清楚解决方案是什么我还查看了具有类似错误的所有主题 但无法解决我的问题 这里的错误 我的应用程序是基于 Groovy 和 Grails 版本 2 0 4 构建的 A fatal error has be
  • 使用 bash 通过 ssh 启动进程,然后在 sigint 上终止它

    我想使用 ssh 在不同的机器上启动几个作业 如果用户随后中断主脚本 我想优雅地关闭所有作业 这是我正在尝试做的事情的一个简短示例 bin bash trap aborted SIGINT SIGTERM aborted kill SIGT
  • 每个键的填充数据帧和累积度量 Pandas

    我有以下数据框 import pandas as pd before padding pd DataFrame data user id 1 1 1 1 2 2 3 days past 1 2 3 4 2 3 2 pay 11 12 13
  • tesseract (v3.03) 输出为 PDF [关闭]

    Closed 这个问题不符合堆栈溢出指南 help closed questions 目前不接受答案 为什么会返回这个错误呢 root amd 3700 2gb ocr test tesseract l dan pdf png out pd
  • 无法加载动态库'C:\php\ext\php_pthreads.dll'

    我试图在我的 php 代码中添加线程 但我无法理解pthreads库 每次运行程序时都会遇到此错误 Warning PHP Startup Unable to load dynamic library C php ext php pthre
  • 通过多种方法进行 Spring JPA 事务

    我在 Tomcat 7 中运行的 Web 应用程序中使用带有 JPA 和 Hibernate 4 的 Spring 3 2 该应用程序分为控制器 服务和 DAO 类 服务类在类和方法级别具有带注释的事务配置 DAO 是普通的 JPA 带有通
  • Java 堆被无法访问的对象淹没

    我们的 Java EE 应用程序开始出现一些严重问题 具体来说 应用程序在启动后几分钟内就运行了高达 99 的老年代堆 不会抛出 OOM 但实际上 JVM 没有响应 jstat 显示老年代的大小根本没有减少 没有垃圾收集正在进行 并且kil
  • 防止 TWIG 删除变量前的空格

    我有这个用例 范围内的默认文本 将在整个页面中使用 使用 jQuery 将文本从 占位符 更改为 特定情况 Ie 在 html 中我想这样做 树枝 html 和 js block content set location span Some
  • MassTransit 是否支持基于 HTTP 传输的 MSMQ?

    HTTP 传输自 MSMQ 3 0 起就可用 但恐怕 MassTransit 不提供使用 HTTP 协议作为队列之间的传输协议的功能 关于这个有一个非常相似的问题here https stackoverflow com questions