Vulild.Service
将第三方服务抽象成服务对象，与业务层解耦，同样适用于微服务中服务变更场景
一、初始化服务信息。
Vulild.Core.Assmblys.AssmblyUtil.SearchAllAssmbly(ServiceUtil.TypeDeal);二、添加服务配置信息（以kafka为例）
ServiceUtil.InitService(
"kafkatest",
new KafkaServiceOption
{
Hosts = new List<string> { "199.199.199.64:9091", "199.199.199.64:9092", "199.199.199.64:9093" },
GroupId = "vulild"
});三、调用服务
kafka支持Topic模式的发布订阅。代码如下：
1）生产者
var produceService = ServiceUtil.GetService<ITopicProducerService>();//获取生产者服务，此处依赖IQueueProducerService，不依赖具体实现。
produceService.SendTopicMessage("vulild", new TestData { Ticks = ticks });2）消费者
public void ConsumerTest()
{
var consumerService = ServiceUtil.GetService<ITopicConsumerService>();
CancellationTokenSource cts = new CancellationTokenSource();
consumerService.OnMessage += OnMessage;
consumerService.SubscribeTopic(new List<string> { "vulild" }, cts.Token);
}
static void OnMessage(string topic, string message)
{
Console.WriteLine(message);
}四、更换服务
若想更换服务，比如从kafka更换到activemq，则只需更换初始化代码的配置项即可,从而达到服务和业务解耦的目的，代码如下：
//ServiceUtil.InitService(
// "kafkatest",
// new KafkaServiceOption
// {
// Hosts = new List<string> { "199.199.199.64:9091", //"199.199.199.64:9092", "199.199.199.64:9093" },
// GroupId = "vulild"
// });
ServiceUtil.InitService("activemqtest",
new ActiveMqServiceOption()
{
Hosts = new List<string> { "tcp://127.0.0.1:61616" },
Password = "密码",
UserName = "用户名"
});
