# Vulild.Service

**Repository Path**: vulild/Vulild.Service

## Basic Information

- **Project Name**: Vulild.Service
- **Description**: 将第三方服务抽象成服务对象，与业务层解耦，同样适用于微服务中服务变更场景
- **Primary Language**: C#
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 3
- **Forks**: 0
- **Created**: 2020-12-13
- **Last Updated**: 2022-10-09

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Vulild.Service
将第三方服务抽象成服务对象，与业务层解耦，同样适用于微服务中服务变更场景

一、初始化服务信息。

```c#
Vulild.Core.Assmblys.AssmblyUtil.SearchAllAssmbly(ServiceUtil.TypeDeal);
```

二、添加服务配置信息（以kafka为例）

```c#
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）生产者

```c#
var produceService = ServiceUtil.GetService<ITopicProducerService>();//获取生产者服务，此处依赖IQueueProducerService，不依赖具体实现。
produceService.SendTopicMessage("vulild", new TestData { Ticks = ticks });
```

2）消费者

```c#
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，则只需更换初始化代码的配置项即可,从而达到服务和业务解耦的目的，代码如下：

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