Skip to content

Commit f545b28

Browse files
author
283591387@qq.com
committed
屏蔽kafka代码
1 parent 5b36b62 commit f545b28

File tree

14 files changed

+674
-676
lines changed

14 files changed

+674
-676
lines changed

‎Vue.Net/VOL.Core/Extensions/AutofacManager/AutofacContainerModuleExtension.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@
1919
using VOL.Core.EFDbContext;
2020
using VOL.Core.Enums;
2121
using VOL.Core.Extensions.AutofacManager;
22-
using VOL.Core.KafkaManager.IService;
23-
using VOL.Core.KafkaManager.Service;
22+
//using VOL.Core.KafkaManager.IService;
23+
//using VOL.Core.KafkaManager.Service;
2424
using VOL.Core.ManageUser;
2525
using VOL.Core.ObjectActionValidator;
2626
using VOL.Core.Services;
@@ -94,10 +94,10 @@ public static IServiceCollection AddModule(this IServiceCollection services, Con
9494
builder.RegisterType<MemoryCacheService>().As<ICacheService>().SingleInstance();
9595
}
9696
//kafka注入
97-
if (AppSetting.Kafka.UseConsumer)
98-
builder.RegisterType<KafkaConsumer<string, string>>().As<IKafkaConsumer<string, string>>().SingleInstance();
99-
if (AppSetting.Kafka.UseProducer)
100-
builder.RegisterType<KafkaProducer<string, string>>().As<IKafkaProducer<string, string>>().SingleInstance();
97+
//if (AppSetting.Kafka.UseConsumer)
98+
// builder.RegisterType<KafkaConsumer<string, string>>().As<IKafkaConsumer<string, string>>().SingleInstance();
99+
//if (AppSetting.Kafka.UseProducer)
100+
// builder.RegisterType<KafkaProducer<string, string>>().As<IKafkaProducer<string, string>>().SingleInstance();
101101
return services;
102102
}
103103

‎Vue.Net/VOL.Core/KafkaManager/IService/IKafkaConsumer.cs

Lines changed: 37 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -1,41 +1,41 @@
1-
using Confluent.Kafka;
2-
using System;
3-
using System.Collections.Generic;
4-
using System.Text;
1+
//using Confluent.Kafka;
2+
//using System;
3+
//using System.Collections.Generic;
4+
//using System.Text;
55

6-
namespace VOL.Core.KafkaManager.IService
7-
{
8-
public interface IKafkaConsumer<TKey, TValue> : IDisposable
9-
{
10-
/// <summary>
11-
/// 订阅回调模式-消费(持续订阅)
12-
/// </summary>
13-
/// <param name="Func">回调函数,若配置为非自动提交(默认为否),则通过回调函数的返回值判断是否提交</param>
14-
/// <param name="Topic">主题</param>
15-
void Consume(Func<ConsumeResult<TKey, TValue>, bool> Func, string Topic);
6+
//namespace VOL.Core.KafkaManager.IService
7+
//{
8+
// public interface IKafkaConsumer<TKey, TValue> : IDisposable
9+
// {
10+
// /// <summary>
11+
// /// 订阅回调模式-消费(持续订阅)
12+
// /// </summary>
13+
// /// <param name="Func">回调函数,若配置为非自动提交(默认为否),则通过回调函数的返回值判断是否提交</param>
14+
// /// <param name="Topic">主题</param>
15+
// void Consume(Func<ConsumeResult<TKey, TValue>, bool> Func, string Topic);
1616

17-
/// <summary>
18-
/// 批量订阅回调模式-消费(持续订阅)
19-
/// </summary>
20-
/// <param name="Func">回调函数,若配置为非自动提交(默认为否),则通过回调函数的返回值判断是否提交</param>
21-
/// <param name="Topics">主题集合</param>
22-
void ConsumeBatch(Func<ConsumeResult<TKey, TValue>, bool> Func, List<string> Topics);
17+
// /// <summary>
18+
// /// 批量订阅回调模式-消费(持续订阅)
19+
// /// </summary>
20+
// /// <param name="Func">回调函数,若配置为非自动提交(默认为否),则通过回调函数的返回值判断是否提交</param>
21+
// /// <param name="Topics">主题集合</param>
22+
// void ConsumeBatch(Func<ConsumeResult<TKey, TValue>, bool> Func, List<string> Topics);
2323

24-
/// <summary>
25-
/// 批量消费模式-单次消费(消费出当前Kafka缓存的所有数据,并持续监听 300ms,如无新数据生产,则返回(最多一次消费 100条)
26-
/// </summary>
27-
/// <param name="Topic">主题</param>
28-
/// <param name="TimeOut">持续监听时间,单位ms 默认值:300ms</param>
29-
/// <param name="MaxRow">最多单次消费行数 默认值:100行</param>
30-
/// <returns>待消费数据</returns>
31-
List<ConsumeResult<TKey, TValue>> ConsumeOnce(string Topic, int TimeOut = 300, int MaxRow = 100);
24+
// /// <summary>
25+
// /// 批量消费模式-单次消费(消费出当前Kafka缓存的所有数据,并持续监听 300ms,如无新数据生产,则返回(最多一次消费 100条)
26+
// /// </summary>
27+
// /// <param name="Topic">主题</param>
28+
// /// <param name="TimeOut">持续监听时间,单位ms 默认值:300ms</param>
29+
// /// <param name="MaxRow">最多单次消费行数 默认值:100行</param>
30+
// /// <returns>待消费数据</returns>
31+
// List<ConsumeResult<TKey, TValue>> ConsumeOnce(string Topic, int TimeOut = 300, int MaxRow = 100);
3232

33-
/// <summary>
34-
/// 单笔消费模式-单行消费
35-
/// </summary>
36-
/// <param name="Topic">主题</param>
37-
/// <param name="TimeOut">持续监听时间,单位ms 默认值:300ms</param>
38-
/// <returns>待消费数据</returns>
39-
ConsumeResult<TKey, TValue> ConsumeOneRow(string Topic, int TimeOut = 300);
40-
}
41-
}
33+
// /// <summary>
34+
// /// 单笔消费模式-单行消费
35+
// /// </summary>
36+
// /// <param name="Topic">主题</param>
37+
// /// <param name="TimeOut">持续监听时间,单位ms 默认值:300ms</param>
38+
// /// <returns>待消费数据</returns>
39+
// ConsumeResult<TKey, TValue> ConsumeOneRow(string Topic, int TimeOut = 300);
40+
// }
41+
//}

‎Vue.Net/VOL.Core/KafkaManager/IService/IKafkaProducer.cs

Lines changed: 25 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -1,28 +1,28 @@
1-
using System;
2-
using System.Collections.Generic;
3-
using System.Text;
4-
using System.Threading.Tasks;
1+
//using System;
2+
//using System.Collections.Generic;
3+
//using System.Text;
4+
//using System.Threading.Tasks;
55

6-
namespace VOL.Core.KafkaManager.IService
7-
{
8-
public interface IKafkaProducer<TKey, TValue>
9-
{
10-
/// <summary>
11-
/// 生产
12-
/// </summary>
13-
/// <param name="Key"></param>
14-
/// <param name="Value"></param>
15-
/// <param name="Topic"></param>
16-
void Produce(TKey Key, TValue Value, string Topic);
6+
//namespace VOL.Core.KafkaManager.IService
7+
//{
8+
// public interface IKafkaProducer<TKey, TValue>
9+
// {
10+
// /// <summary>
11+
// /// 生产
12+
// /// </summary>
13+
// /// <param name="Key"></param>
14+
// /// <param name="Value"></param>
15+
// /// <param name="Topic"></param>
16+
// void Produce(TKey Key, TValue Value, string Topic);
1717

18-
/// <summary>
19-
/// 生产 异步
20-
/// </summary>
21-
/// <param name="Key"></param>
22-
/// <param name="Value"></param>
23-
/// <param name="Topic"></param>
24-
/// <returns></returns>
25-
Task ProduceAsync(TKey Key, TValue Value, string Topic);
18+
// /// <summary>
19+
// /// 生产 异步
20+
// /// </summary>
21+
// /// <param name="Key"></param>
22+
// /// <param name="Value"></param>
23+
// /// <param name="Topic"></param>
24+
// /// <returns></returns>
25+
// Task ProduceAsync(TKey Key, TValue Value, string Topic);
2626

27-
}
28-
}
27+
// }
28+
//}

‎Vue.Net/VOL.Core/KafkaManager/KafkaConfig.cs

Lines changed: 44 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -1,48 +1,48 @@
1-
using Confluent.Kafka;
2-
using System;
3-
using System.Collections.Generic;
4-
using System.Text;
5-
using VOL.Core.Configuration;
1+
////using Confluent.Kafka;
2+
//using System;
3+
//using System.Collections.Generic;
4+
//using System.Text;
5+
//using VOL.Core.Configuration;
66

7-
namespace VOL.Core.KafkaManager
8-
{
9-
/// <summary>
10-
/// 配置类
11-
/// </summary>
12-
public class KafkaConfig
13-
{
14-
/// <summary>
15-
/// 构造配置类
16-
/// </summary>
17-
protected KafkaConfig()
18-
{
19-
ProducerConfig = new ProducerConfig()
20-
{
21-
BootstrapServers = AppSetting.Kafka.ProducerSettings.BootstrapServers,// "192.168.20.241:9092",
22-
};
7+
//namespace VOL.Core.KafkaManager
8+
//{
9+
// /// <summary>
10+
// /// 配置类
11+
// /// </summary>
12+
// public class KafkaConfig
13+
// {
14+
// /// <summary>
15+
// /// 构造配置类
16+
// /// </summary>
17+
// protected KafkaConfig()
18+
// {
19+
// //ProducerConfig = new ProducerConfig()
20+
// //{
21+
// // BootstrapServers = AppSetting.Kafka.ProducerSettings.BootstrapServers,// "192.168.20.241:9092",
22+
// //};
2323

24-
ConsumerConfig = new ConsumerConfig()
25-
{
26-
BootstrapServers = AppSetting.Kafka.ConsumerSettings.BootstrapServers,
27-
GroupId = AppSetting.Kafka.ConsumerSettings.GroupId,
28-
AutoOffsetReset = AutoOffsetReset.Earliest,//当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
29-
EnableAutoCommit = false,
30-
//Kafka配置安全认证
31-
//SecurityProtocol = SecurityProtocol.SaslPlaintext,
32-
//SaslMechanism = SaslMechanism.Plain,
33-
//SaslUsername = AppSetting.Kafka.ConsumerSettings.SaslUsername,
34-
//SaslPassword = AppSetting.Kafka.ConsumerSettings.SaslPassword,
35-
};
36-
}
24+
// //ConsumerConfig = new ConsumerConfig()
25+
// //{
26+
// // BootstrapServers = AppSetting.Kafka.ConsumerSettings.BootstrapServers,
27+
// // GroupId = AppSetting.Kafka.ConsumerSettings.GroupId,
28+
// // AutoOffsetReset = AutoOffsetReset.Earliest,//当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
29+
// // EnableAutoCommit = false,
30+
// // //Kafka配置安全认证
31+
// // //SecurityProtocol = SecurityProtocol.SaslPlaintext,
32+
// // //SaslMechanism = SaslMechanism.Plain,
33+
// // //SaslUsername = AppSetting.Kafka.ConsumerSettings.SaslUsername,
34+
// // //SaslPassword = AppSetting.Kafka.ConsumerSettings.SaslPassword,
35+
// //};
36+
// }
3737

38-
/// <summary>
39-
/// 消费者配置文件
40-
/// </summary>
41-
public ConsumerConfig ConsumerConfig;
38+
// ///// <summary>
39+
// ///// 消费者配置文件
40+
// ///// </summary>
41+
// //public ConsumerConfig ConsumerConfig;
4242

43-
/// <summary>
44-
/// 生产者配置文件
45-
/// </summary>
46-
public ProducerConfig ProducerConfig;
47-
}
48-
}
43+
// ///// <summary>
44+
// ///// 生产者配置文件
45+
// ///// </summary>
46+
// //public ProducerConfig ProducerConfig;
47+
// }
48+
//}

0 commit comments

Comments
 (0)