- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我最近遇到了很多问题,因为 MassTransit.UnityIntegration
软件包中似乎有一个错误,主要是由于未考虑注册名称的事实。
例如,如果我像这样注册我的类(class):
var container = new UnityContainer()
.RegisterType<Consumes<Command1>.All, Handler1>("Handler1")
.RegisterType<Consumes<Command1>.All, Handler3>("Handler3");
LoadFrom
扩展方法来在容器中获取已注册的使用者,如下所示:
IServiceBus massTransitBus = ServiceBusFactory.New(_sbc =>
{
_sbc.UseBinarySerializer();
_sbc.UseControlBus();
_sbc.ReceiveFrom("msmq://localhost/MyQueue");
_sbc.UseMsmq(_x =>
{
_x.UseSubscriptionService("msmq://localhost/mt_subscriptions");
_x.VerifyMsmqConfiguration();
});
_sbc.Subscribe(_s => _s.LoadFrom(container));
});
LoadFrom
方法内部的主要代码:
public static void LoadFrom(this SubscriptionBusServiceConfigurator configurator, IUnityContainer container)
{
IList<Type> concreteTypes = FindTypes<IConsumer>(container, x => !x.Implements<ISaga>());
if (concreteTypes.Count > 0)
{
var consumerConfigurator = new UnityConsumerFactoryConfigurator(configurator, container);
foreach (Type concreteType in concreteTypes)
consumerConfigurator.ConfigureConsumer(concreteType);
}
...
}
FindTypes<T>
的实现:
static IList<Type> FindTypes<T>(IUnityContainer container, Func<Type, bool> filter)
{
return container.Registrations
.Where(r => r.MappedToType.Implements<T>())
.Select(r => r.MappedToType)
.Where(filter)
.ToList();
}
UnityConsumerFactory<T>
类内部的这一行上,该行实际上创建了使用者的实例:
var consumer = childContainer.Resolve<T>();
RegisterType
调用中为其命名,然后在
Resolve
调用中指定该名称。
Type
,而且传递用于注册的名称。
var container = new UnityContainer()
.RegisterType<Handler1>()
.RegisterType<Handler3>();
ICommandHandler<TCommand>
,其中
TCommand
是系统中命令的基本模型。当我们开始考虑使用服务总线时,从一开始就很清楚地知道,以后应该可以很容易地切换到另一种服务总线实现。考虑到这一点,我开始在我们的命令界面上创建一个抽象,使其表现像MT期望的消费者之一。这是我想出的:
public class CommandHandlerToConsumerAdapter<T> : Consumes<T>.All
where T : class, ICommand
{
private readonly ICommandHandler<T> _commandHandler;
public CommandHandlerToConsumerAdapter(ICommandHandler<T> commandHandler)
{
_commandHandler = commandHandler;
}
public void Consume(T _message)
{
_commandHandler.Handle(_message);
}
}
ICommandHandler<T>
实现,并使它的行为类似于
Consumes<T>.All
实例。遗憾的是
MT required message models to be classes,因为我们的命令没有该约束,但这是一个小麻烦,我们继续将
where T : class
约束添加到我们的接口(interface)中。
.RegisterType<ICommandHandler<ApplicationInstallationCommand>, CommandRecorder>("Recorder")
.RegisterType<ICommandHandler<ApplicationInstallationCommand>, InstallOperation>("Executor")
.RegisterType<Consumes<ApplicationInstallationResult>.All, CommandHandlerToConsumerAdapter<ApplicationInstallationResult>>()
.RegisterType<Consumes<ApplicationInstallationCommand>.All, CommandHandlerToConsumerAdapter<ApplicationInstallationCommand>>
("Recorder", new InjectionConstructor(new ResolvedParameter<ICommandHandler<ApplicationInstallationCommand>>("Recorder")))
.RegisterType<Consumes<ApplicationInstallationCommand>.All, CommandHandlerToConsumerAdapter<ApplicationInstallationCommand>>
("Executor", new InjectionConstructor(new ResolvedParameter<ICommandHandler<ApplicationInstallationCommand>>("Executor")))
_sbc.Consume(() => container.resolve<Consumes<ApplicationInstallationCommand>.All>("Recorder"))
CommandHandlerToConsumerAdapter<ApplicationInstallationCommand>
实例,该实例实现了
Consumes<ApplicationInstallationCommand>.All
,该实例又应成为受支持的THE基本接口(interface)之一。在此之后立即发布
ApplicationInstallationCommand
无效,就好像处理程序无效或类似。
_sbc.Consume(() => (CommandHandlerToConsumerAdapter<ApplicationInstallationCommand>) container.resolve<Consumes<ApplicationInstallationCommand>.All>("Recorder"))
Consumes<X>.All
,在编译时仍需要具体类型来查看它是消息处理程序?
Consumer
调用。
public static class CommandHandlerEx
{
public static CommandHandlerToConsumerAdapter<T> ToConsumer<T>(this ICommandHandler<T> _handler)
where T : class, ICommand
{
return new CommandHandlerToConsumerAdapter<T>(_handler);
}
}
var container = new UnityContainer()
.RegisterType<ICommandHandler<ApplicationInstallationCommand>, CommandRecorder>("Recorder")
.RegisterType<ICommandHandler<ApplicationInstallationCommand>, InstallOperation>("Executor");
IServiceBus massTransitBus = ServiceBusFactory.New(_sbc =>
{
_sbc.UseBinarySerializer();
_sbc.UseControlBus();
_sbc.ReceiveFrom("msmq://localhost/MyQueue");
_sbc.UseMsmq(_x =>
{
_x.UseSubscriptionService("msmq://localhost/mt_subscriptions");
_x.VerifyMsmqConfiguration();
});
_sbc.Subscribe(RegisterConsumers);
});
private void RegisterConsumers(SubscriptionBusServiceConfigurator _s)
{
_s.Consumer(() => container.Resolve<ICommandHandler<ApplicationInstallationCommand>>("Recorder").ToConsumer());
_s.Consumer(() => container.Resolve<ICommandHandler<ApplicationInstallationCommand>>("Executor").ToConsumer());
}
Resolve
或ResolveAll
(或非Unity术语中的等效项),而不必关心确切注册的内容及其具体类型。假设容器可以返回未显式注册的类型,则这会对代码产生严重后果。幸运的是,这些类并非如此,但是我们有一个容器扩展,可以根据构建键自动创建装饰器类型,并且不需要在容器上显式注册它们。 MappedToType
实例上的ContainerRegistration
属性来调用容器上的Resolve
。这在任何情况下都是完全错误的,而不仅仅是在MassTransit的上下文中。 Unity中的类型要么注册为映射(如上述摘录中的From
和To
组件),要么直接注册为单个具体类型。在两种情况下,逻辑都应使用RegisteredType
类型从容器中解析。现在的工作方式是,如果您碰巧使用其接口(interface)注册了处理程序,则MT将完全绕过您的注册逻辑,而是对具体类型works in Unity out of the box调用resolve,这可能会导致不可预测的行为,因为您认为它应该是单例就像您注册的一样,但是最终它变成了一个临时对象(默认值)。 public sealed class CommandHandlerToConsumerAdapter<T>
where T : class, ICommand
{
public sealed class All : Consumes<T>.All
{
private readonly ICommandHandler<T> m_commandHandler;
public All(ICommandHandler<T> _commandHandler)
{
m_commandHandler = _commandHandler;
}
public void Consume(T _message)
{
m_commandHandler.Handle(_message);
}
}
}
ToShortTypeName
的扩展方法)上未处理的异常,这破坏了MassTransit的代码。
at System.String.Substring(Int32 startIndex, Int32 length)
at Magnum.Extensions.ExtensionsToType.ToShortTypeName(Type type)
at MassTransit.Pipeline.Sinks.ConsumerMessageSink2.<>c__DisplayClass1.<Selector>b__0(IConsumeContext
1 context) in d:\BuildAgent-02\work\aa063b4295dfc097\src\MassTransit\Pipeline\Sinks\ConsumerMessageSink.cs:line 51 at MassTransit.Pipeline.Sinks.InboundConvertMessageSink`1.<>c__DisplayClass2.<>c__DisplayClass4.b__1(IConsumeContext x) in d:\BuildAgent-02\work\aa063b4295dfc097\src\MassTransit\Pipeline\Sinks\InboundConvertMessageSink.cs:line 45 at MassTransit.Context.ServiceBusReceiveContext.DeliverMessageToConsumers(IReceiveContext context) in d:\BuildAgent-02\work\aa063b4295dfc097\src\MassTransit\Context\ServiceBusReceiveContext.cs:line 162
最佳答案
尽管我不了解Unity与所有容器的集成,但是您必须将使用者注册为容器中的具体类型,而不是Consumes<>
接口(interface)。我认为这只是RegisterType<Handler1, Handler1>()
,但我对此不太确定。
如果您不喜欢容器的LoadFrom
扩展名,则无需使用它。您始终可以自己解决使用者,并通过_sbc.Consume(() => container.resolve<YourConsumerType>())
在配置中注册他们。 LoadFrom
扩展对于以常见方式使用容器的人来说服了。
以下代码可以正常工作,它以我期望的方式使用容器,而又不了解您的域,因此可以使用它。如果您想更好地了解消息的绑定(bind)方式,建议您使用RabbitMQ,因为您可以通过放弃交换绑定(bind)来轻松了解最终的结果。在这一点上,这已经远远超出了SO的问题,如果您还有其他任何疑问,我会将其带到邮件列表中。
using System;
using MassTransit;
using Microsoft.Practices.Unity;
namespace MT_Unity
{
class Program
{
static void Main(string[] args)
{
using (var container = new UnityContainer()
.RegisterType<ICommandHandler<MyCommand>, MyCommandHandler>()
.RegisterType<CommandHandlerToConsumerAdapter<MyCommand>>())
using (IServiceBus consumerBus = ServiceBusFactory.New(sbc =>
{
sbc.ReceiveFrom("rabbitmq://localhost/consumer");
sbc.UseRabbitMq();
sbc.Subscribe(s => s.Consumer(() => container.Resolve<CommandHandlerToConsumerAdapter<MyCommand>>()));
}))
using (IServiceBus publisherBus = ServiceBusFactory.New(sbc =>
{
sbc.ReceiveFrom("rabbitmq://localhost/publisher");
sbc.UseRabbitMq();
}))
{
publisherBus.Publish(new MyCommand());
Console.ReadKey();
}
}
}
public class CommandHandlerToConsumerAdapter<T> : Consumes<T>.All where T : class, ICommand
{
private readonly ICommandHandler<T> _commandHandler;
public CommandHandlerToConsumerAdapter(ICommandHandler<T> commandHandler)
{
_commandHandler = commandHandler;
}
public void Consume(T message)
{
_commandHandler.Handle(message);
}
}
public interface ICommand { }
public class MyCommand : ICommand { }
public interface ICommandHandler<T> where T : class, ICommand
{
void Handle(T message);
}
public class MyCommandHandler : ICommandHandler<MyCommand>
{
public MyCommandHandler()
{
}
public void Handle(MyCommand message)
{
Console.WriteLine("Handled MyCommand");
}
}
}
关于.net - 通过Unity的同一条消息的多个使用者在MassTransit中不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20710607/
在撰写本文时,Unity 有一个名为 Unity LTS 2017.4.12f1 的版本,Unity 的最新版本是 2018.2.11 我知道 Unity LTS 应该是稳定版本,但这是否意味着 Un
我需要 Unity 来捕获所有按键,即使 Unity 没有焦点。 我尝试过使用: Input.KeyPress() 但这似乎只有在 Unity 拥有用户输入焦点的情况下才有效。我需要它在没有焦点时工作
我正在尝试统一实现一个TCP服务器。我正在使用 unity pro 3.5,当我在场景中运行此代码时,unity 挂起,完全没有响应,直到我用任务管理器杀死它。 using UnityEngine;
我想问一下,使用新的unity ads 2.0与unity ads相比,收入有什么区别 Unity Ads Unity Ads 2.0 最佳答案 Unity 广告支持 Unity 4.2.2 或更高版
当我运行我的应用程序时,我希望 Unity 打开两个窗口。 window 将有不同的摄像头,但两者都会看到同一个世界。 这样的事情可能吗? (我还没有找到任何证据表明这一点) 我知道我可以通过两个 U
我使用Unity Hub下载了最新的Unity编辑器,它对于编辑器、文档和语言包运行良好,但无法下载android构建支持。刚刚告诉我这两天下载失败很多次。 所以我从网页下载了UnitySetup-A
我使用Unity Hub下载了最新的Unity编辑器,它对于编辑器、文档和语言包运行良好,但无法下载android构建支持。刚刚告诉我这两天下载失败很多次。 所以我从网页下载了UnitySetup-A
我今天已将我的项目升级到 Prism 6.3.0 和 Unity 5.3.1。在此之前,我有 Prism 5 和 Unity 4。 现在我遇到了 Prism.Unity.UnityBootstrapp
Unity 中是否有与 StructureMap 中的 Registry 类等效的内容? 我喜欢考虑一个层/组件/库来自行配置它 - 从而填充容器。所以“父”层只需要知道注册类。 最佳答案 不,没有。
我似乎无法在任何地方找到 Microsoft.Practices.Unity.StaticFactory.dll。 还有其他注册静态工厂的方法吗? 寻找这样的东西 container.Register
是否可以统一尝试所有已定义的构造函数,从参数最多的构造函数到最不具体的构造函数(默认构造函数)? 编辑 我的意思是说: foreach (var constructor in concrete.Get
我有一个正在运行且运行良好的 Unity 应用程序,但我们目前正在通过对所有编译警告采取行动来清理我们的代码。 由于过时的 Microsoft.Practices.Unity.Configuratio
我正在使用 Visual Studio Code 在 Unity 中编写脚本。在“编辑”-“首选项”-“外部工具”-“外部脚本编辑器”下,我也选择了 VS Code。 打开脚本工作正常,但是当我尝试通
因此,我很确定这不是提出此类问题的正确论坛,因此我非常感谢有人将我链接到针对此问题的更好论坛(如果需要)。 我的问题: 在 Unity Hub 中,我进行了设置,以便 Unity 编辑器应下载到我的硬
问题:即使在 Cardboard 相机范围内,我也无法在任何地方看到我的 UI 文本。 截图: 我使用的是Unity 5.4.0b21版本,有人说可以通过降级到Unity 5.3版本来修复。 但是,我
我正在开发一个 Unity 项目,我正在使用 Google VR SDK for Unity 和 FirebaseMessaging.unitypackage 适用于 Unity 的 Firebase
好吧,在谷歌、这里和几个 ASP/MVC 论坛上搜索之后,我一定要问我到底做错了什么。 我的应用程序有一个良好的开端,对 DI、IoC 有很好的理解,并且正在使用 Repository、Service
我们最近将项目中的 Microsoft Unity 从 3.5.1404 版本升级到 5.8.6。在我们的代码中只做了一些小的调整,这次升级似乎很容易。它毫无问题地解决了我们所有注册的实例。但是,我们
我正在弄清楚使用 Unity 应用程序 block 时的意外行为。我有项目 A 作为我的启动项目。 项目 A 具有对项目 B 的项目引用,而项目 B 具有对项目 C 的项目引用。 项目 A 使用 un
我将 Unity 与 MVC 和 NHibernate 结合使用。不幸的是,我们的 UnitOfWork 驻留在不同的 .dll 中,并且它没有默认的空 .ctor。这是我注册 NHibernate
我是一名优秀的程序员,十分优秀!