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 = "用户名"
     });