Блог

Я очень новичок в DI и autofac. У меня есть одноэлементный класс ProducerService , как указано ниже. Это используется как зависимость в конструкторе BackgroundService. В ProducerService есть зависимость, введенная конструктором, IKafkaProducerAggregate , также перечисленная ниже.

Как я могу создать единственный экземпляр IKafkaProducerAggregate<TKey, Tvalue> , который создается для внедрения в ProducerService<TKey, TValue> ? Это содержит экземпляр IProducer из внешней библиотеки Kafka confluent dotnet с помощью заводского метода IProducer<TKey, TValue> producer = new ProducerBuilder<TKey, TValue>(Config.Producer).Build(); . Могу ли я использовать какой-то заводской метод с Autofac, который создает экземпляр aggregate и инициализирует IProducer с помощью фабричного метода Kafka confluences?

Пока у меня есть модуль Autofac, который регистрирует службу производителя, и я изо всех сил пытаюсь понять, как использовать что-то похожее на заводской метод??? это создало бы IKafkaProducerAggregate при создании ProducerService :

 Assembly serializers = typeof(ConsumerService).GetTypeInfo().Assembly;

builder.RegisterGeneric(typeof(ProducerService<,>))
    .As(typeof(IKafkaProducer<,>))
    .SingleInstance();
  

Интерфейс: IKafkaProducerAggregate

 public interface IKafkaProducerAggregate<TKey, TValue>
{
    IProducer<TKey, TValue> Producer { get; }
    Action<DeliveryReport<TKey, TValue>> DeliveryReportAction { get; }
}
  

Класс: ProducerService

 namespace WebApp.Kafka
{
    public class ProducerService<Key, Value> : IProducerService<Key, Value>, IDisposable
    {
        private bool Disposed { get; set; }
        private IKafkaProducerAggregate<Key, Value> ProducerAggregate { get; }
        private ILogger Logger { get; set; }


        ProducerService(
            IKafkaProducerAggregate<Key, Value> aggregate,
            ILogger<ProducerService<Key, Value>> logger)
        {
            Logger = logger ?? throw new ArgumentNullException(nameof(logger));
            ProducerAggregate = aggregate ?? throw new ArgumentNullException(nameof(aggregate));

            Disposed = false;

            Logger.LogInformation("ProducerService constructor called");
        }

        public void Produce(string topic, Key key, Value value)
        {
            ProducerAggregate.Producer.Produce(topic, new Message<Key, Value> { Key = key, Value = value }, ProducerAggregate.DeliveryReportAction);

            Logger.LogInformation("Produce topic : {}, key : {}, value : {}", topic, key.ToString(), value.ToString());
        }

        public void Dispose()
        {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

        protected virtual void Dispose(bool disposing)
        {
            if (!Disposed)
            {
                if (disposing)
                {
                    Logger.LogInformation("Disposing Kafka producer...");
                    ProducerAggregate.Producer.Dispose();
                }

                Disposed = true;
            }
        }

        ~ProducerService()
        {
            Dispose(false);
        }
    }
}
  

Вам не нужна какая-либо фабрика, чтобы создать новый экземпляр зависимости, который будет создан в конструкторе, вам просто нужно использовать область времени существования InstancePerDependency, а не singleInstance .

https://autofaccn.readthedocs.io/en/latest/lifetime/instance-scope.html