问题标签 [masstransit]

请帮助我开始

周末我一直在冲浪，对不起我的法语，没有找到我要找的东西。

这是我试图移动到消息队列的过程

• 每天晚上 pdf 文件都会登陆我们的 ftp 服务器，大约有 45,000 个。
• 对于每个文件，在 ms sql server 中的队列表中创建一条记录
• 服务正在读取队列并处理磁盘上的文件。

这就是我想要的带有事务和错误处理的 pub/sub

• 文件观察器写入事务中的队列而不是数据库。我想这个更快。
• 然后我想订阅 pdf- 队列，这样我就不必在新文件到达时轮询数据库。

一些问题

• 如何将事务发布到队列？
• 如何从队列中检索消息，然后在处理消息时出现错误时中止。
• 打开/关闭队列连接的最佳方式是什么？是否有轻量级会话对象？

是的，我知道有一个简单的发布/订阅示例 :-) 但我无法将它们粘合在一起

任何帮助深表感谢。

我正在尝试使用 MassTransit，我使用 nuget 安装了它，并且只使用了他们的基本示例：

快速入门指南

当我运行此代码时，我得到一个异常（列出了内部异常）：

• “创建服务总线时引发异常”
• “创建总线服务失败：SubscriptionRouterService”
• “msmq-pgm://235.109.116.115:7784/test_queue_control_subscriptions => 发送期间抛出异常”
• "长度不能小于零。\r\n参数名称: 长度"

有没有人可以帮助我克服这个错误？

注意：MSMQ 已安装，我已将它用于基于 WCF 的 MSMQ 服务。所有队列看起来都是在错误行之前在 MSMQ 中创建的

尝试从 github 构建 masstransit 源时，我不断收到以下错误：

使用 --trace 开关，我得到：

这应该能够开箱即用还是我错过了什么？

我一直在使用 MassTransit 处理电子邮件。使用此代码： http: //meandaspnet.blogspot.com/2009/10/how-to-binary-serialize-mailmessage-for.html我能够对我的电子邮件进行二进制序列化并将它们发布到我的服务总线。他们也得到了正确的处理。

现在我添加了一个新的类型和处理程序：

奇怪的是，如果我发布一个 SerializableMailMessage，这将有效——但不适用于 AangifteOmzetbelasting。如果我更改接口顺序 - 它适用于 AangifteOmzetbelasting 而不是 SerializableMailMessage。像这样：

在后一种情况下，SerializedMailMessges 也不会出现在服务总线上。两者均使用以下方式发布：

我在这里做错了什么？

我们在 Web 应用程序的请求/响应模型中使用 MassTransit。我们能够发送请求并接收响应。出于测试/调试目的，我们将响应处理程序上的 HandleTimeOut 设置为 1 小时。问题是当服务器无法发送响应时，我无法在客户端做任何事情（我无法访问任何其他页面）。在重置 IIS 之前，应用程序服务器不会响应来自浏览器的任何其他请求。这是预期的行为。如果可以的话，有人可以解释一下为什么 IIS 没有响应任何其他页面请求，以及是否有办法改变这种行为。

我在 autofac 模块中注册总线

我的客户端代码如下所示

使用 Mass Transit 和 RabbitMQ 设置对远程端点发布的消息的订阅的建议方法是什么？

在我们的例子中，大多数 pub/sub 是本地的，但我们的开发人员都可以方便地订阅远程机器上的共享发布者。

我看到的所有示例似乎都是本地的： http: //docs.masstransit-project.com/en/latest/configuration/sub_config_api.html

似乎 RabbitMQ 联合可能是一种选择，但看起来更复杂，我们需要：http ://www.rabbitmq.com/federation.html

我的应用程序由一个 ASP.NET MVC 3 应用程序和一个 Windows 服务组成，它们都在同一个盒子上。MVC 应用程序使用 MassTransit 将消息放置在 MSMQ 队列上。该服务使用 MassTransit 从 MSMQ 读取这些消息并执行一些工作。当我加载服务和应用程序并让它们同时运行时，一切似乎都运行良好。但是，如果我只加载 Web 应用程序，我的消息不会被添加到 MSMQ 并且基本上会消失。奇怪的是，如果我加载我的 Web 应用程序，然后启动并立即停止所述服务，则从 Web 应用程序发送的后续消息将添加到队列中。

将 MassTransit 与 StructureMap 和/或 MVC 结合使用的优秀/现代示例并不多，因此我的配置可能存在问题，但经过几个小时的反复试验后，我不确定如何继续。我也可能在滥用 MassTransit - 我真正需要的是来自 Web 应用程序的“一劳永逸”解决方案......

我的服务如下所示：

我的 Web 应用程序如下所示：

任何帮助，将不胜感激！

我的 MassTransit 传奇只有一个字段无法正确映射。这是 -

我试过用几种方法映射它 -

我写了一个单元测试来测试映射 -

我不确定问题到底出在哪里，在映射中还是在测试中。单元测试中的实际错误是 -

有人可以解释如何使用 ClassMap 映射 IDictionary 并使用 PersistenceSpecification ... VerifyMappings() 测试该映射吗？

PS - FluentNHibernate 的版本是 1.3.0.717，NHibernate 的版本是 3.2.0.4000。我确实必须在本地编译它以进行一项次要且不相关的更改。

谢谢！

这是我现在得到的其余错误 -

我正在通过一个简单的示例使用 MassTransit，但我不知道我做错了什么，因为我没有收到正确的数据。我有一个简单的 asp.net-mvc 应用程序，在 HomeController 中有以下代码

如果我调试这段代码，我可以看到 TweetCreatedCommand 是如何发布的，并且 MSMQ 队列中的数据正常，但是当处理程序接收到数据时：TweetCreatedCommand.TweetId 是：00000000-0000-0000-0000-000000000000 应该是其他东西 TweetCreatedCommand.Message 是空的，它应该是“foo！” TweetCreatedCommand.TimeStamp 是 01/01/01 谁为空，应该是“CDA”

怎么了？？

任何帮助，将不胜感激

我已经使用 MassTransit 实现了一个简单的发布者/消费者集，我想让消费者从同一个队列中读取消息。但是，当我运行它时，我看到大部分消息被发送到错误队列而不是被消费。从我看到的讨论（SO，Forum）来看，这对于 RabbitMQ 来说应该非常简单（只需指向同一个队列），但它不起作用。是否应该设置其他配置？

这是我的发布者

我的消费者