public class SignInorOut : KafkaListener { public IServiceProvider _service { get; } public static IAttendanceServices _attendanceServices; public SignInorOut(IOptions<KafkaMessage> options, IServiceProvider service) { _service = service; } public override bool Process(string message) { var mess = JsonConvert.DeserializeObject<syd_trafficInput>(message); if (!string.IsNullOrEmpty(mess.name)) { using (var scope = _service.CreateScope()) { _attendanceServices = scope.ServiceProvider.GetRequiredService<IAttendanceServices>(); _attendanceServices.SignInorOut(mess); } } return true; }
以上红色部分就是相关的使用,为什么我们要使用这种模式使用其中一个对象?因为很多时候是无法使用我们的类的,所以需要使用这种模式来或者某一个对象。
谢谢学习!!!