LinFx

LinFx.Extensions

LinFx.Utils

特性

知识点

设计规范

安装Nuget包

PM> Install-Package LinFx

开发环境

Samples

public void ConfigureServices(IServiceCollection services)
{
 services.AddLinFx()
 .AddDistributedRedisCache(options =>
 {
 options.Configuration = configuration.GetConnectionString("ReidsConnection");
 })
 .AddMongoDBContext(options =>
 {
 options.Name = "default";
 options.Configuration = configuration.GetConnectionString("MongoConnection");
 })
 .AddElasticsearch(options =>
 {
 options.DefaultIndex = "default";
 options.Host = "http://10.0.1.112:9200";
 });
}

EventBus

using LinFx.Extensions.EventBus.Abstractions;
using LinFx.Test.Extensions.EventBus.Events;
using LinFx.Utils;
using LinFx.Extensions.EventBus.RabbitMQ;
using Microsoft.Extensions.DependencyInjection;
using System.Threading.Tasks;
using Xunit;
using LinFx.Test.Extensions.EventBus.EventHandling;
using System.Collections.Generic;
using System;
namespace LinFx.Test.Extensions.EventBus
{
 public class EventBusRabbitMQTest
 {
 private readonly IEventBus _eventBus;
 public EventBusRabbitMQTest()
 {
 var services = new ServiceCollection();
 services.AddLinFx()
 .AddEventBus(options =>
 {
 options.Durable = true;
 options.BrokerName = "tc_cloud_event_bus";
 options.QueueName = "tc_cloud_process_queue";
 options.ConfigureEventBus = (fx, builder) => builder.UseRabbitMQ(fx, x =>
 {
 x.Host = "14.21.34.85";
 x.UserName = "admin";
 x.Password = "admin.123456";
 });
 });
 //services
 services.AddTransient<OrderStatusChangedToAwaitingValidationIntegrationEventHandler>();
 //services.AddTransient<OrderStatusChangedToPaidIntegrationEventHandler>();
 var applicationServices = services.BuildServiceProvider();
 //ConfigureEventBus
 _eventBus = applicationServices.GetRequiredService<IEventBus>();
 _eventBus.Subscribe<OrderStatusChangedToAwaitingValidationIntegrationEvent, OrderStatusChangedToAwaitingValidationIntegrationEventHandler>();
 //eventBus.Subscribe<OrderStatusChangedToPaidIntegrationEvent, OrderStatusChangedToPaidIntegrationEventHandler>();
 }
 [Fact]
 public async Task Should_Call_Handler_On_Event_With_Correct_SourceAsync()
 {
 var orderId = Guid.NewGuid().GetHashCode() & ushort.MaxValue;
 var evt = new OrderStatusChangedToAwaitingValidationIntegrationEvent(orderId, new List<OrderStockItem>
 {
 });
 await _eventBus.PublishAsync(evt);
 //for (int i = 0; i < 2; i++)
 //{
 // await _eventBus.PublishAsync(new ClientCreateIntergrationEvent
 // {
 // ClientId = IDUtils.CreateNewId().ToString(),
 // ClientSecrets = new[] { "191d437f0cc3463b85669f2b570cdc21" },
 // AllowedGrantTypes = new[] { "client_credentials" },
 // AllowedScopes = new[] { "api3.device" }
 // });
 //}
 }
 }
}

RedisCache

using Microsoft.Extensions.Caching.Distributed;
using Microsoft.Extensions.DependencyInjection;
using Xunit;
namespace LinFx.Test.Caching
{
 public class RedisCacheTest
 {
 IDistributedCache _cache;
 public RedisCacheTest()
 {
 var services = new ServiceCollection();
 services.AddLinFx()
 .AddDistributedRedisCache(options =>
 {
 options.Configuration = "10.0.1.112:6379,password=redis";
 options.InstanceName = "linfx_test:";
 });
 var container = services.BuildServiceProvider();
 _cache = container.GetService<IDistributedCache>();
 }
 [Fact]
 public void GetMissingKeyReturnsNull()
 {
 string key = "non-existent-key";
 var result = _cache.Get(key);
 Assert.Null(result);
 }
 [Fact]
 public void SetAndGetReturnsObject()
 {
 var value = new byte[1];
 string key = "myKey";
 _cache.Set(key, value);
 var result = _cache.Get(key);
 Assert.Equal(value, result);
 }
 [Fact]
 public void SetAndGetWorksWithCaseSensitiveKeys()
 {
 var value = new byte[1];
 string key1 = "myKey";
 string key2 = "Mykey";
 _cache.Set(key1, value);
 var result = _cache.Get(key1);
 Assert.Equal(value, result);
 result = _cache.Get(key2);
 Assert.Null(result);
 }
 }
}

MemoryCache

using Microsoft.Extensions.Caching.Distributed;
using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.DependencyInjection;
using Xunit;
namespace LinFx.Test.Caching
{
 public class MemoryCacheTest
 {
 [Fact]
 public void MemoryCacheGetAndSetTests()
 {
 var services = new ServiceCollection();
 services.AddLinFx()
 .AddDistributedMemoryCache();
 var container = services.BuildServiceProvider();
 var _cache = container.GetService<IMemoryCache>();
 var expected = 100;
 _cache.Set("key1", expected);
 var actual = _cache.Get("key1");
 Assert.Equal(expected, actual);
 }
 }
}