个人网站设计模板下载,大数据营销网站,温州做外贸网站,广告营销平台此框架是SQL Server增量订阅#xff0c;用来监听增删改数据库数据变更目前仅支持SQL Server#xff0c;后续会支持MySQL和Oracle#xff0c;Nuget上可以下载安装或者使用Nuget命令添加包dotnet add package Kogel.Subscribe.Mssql --version 0.0.0.1可以用来处理DB主从同步用来监听增删改数据库数据变更目前仅支持SQL Server后续会支持MySQL和OracleNuget上可以下载安装或者使用Nuget命令添加包dotnet add package Kogel.Subscribe.Mssql --version 0.0.0.1 可以用来处理DB主从同步跨库同步数据备份同步ES缓存刷新等等 (一)定义需要监听表的实体类 [Display]和[Identity]属于Kogel.Dapper.Extension的特性如果[想了解更多请点击][ElasticsearchType]和[Nest.PropertyName]属于Elasticsearch特性如果没用到可以忽略 (二)定义表订阅如果需要此表对应多张分表可以设置(1).如果想推送订阅到RabbitMQ中可以通过BuildTopic设置交换机名称builder.BuildTopic(kogel_subscribe_order_detail)(2).如果想推送订阅到Kafka中builder.BuildKafka(new ProducerConfig{BootstrapServers localhost:9092,Acks Acks.None})可以通过BuildTopic设置Topic名称builder.BuildTopic(kogel_subscribe_order_detail)(3).如果想推送订阅到Elasticsearch中builder.BuildElasticsearch(new ElasticsearchConfigOmsOrderDetail{Settings new Nest.ConnectionSettings(new Uri(http://localhost:9200/)),})如果有设置Basic授权builder.BuildElasticsearch(new ElasticsearchConfigOmsOrderDetail
{Settings new Nest.ConnectionSettings(new Uri(http://localhost:9200/)).BasicAuthentication(账号,密码)})如果想根据自己定义的分片逻辑插入到多个ES索引中可以通过WriteInterceptor并且ES索引不存在的时候会动态创建 (4).如果想自定义实现订阅逻辑在可以Subscribe订阅类中重写以上订阅的优先级:(三)订阅启动启动监听所有继承自SubscribeT的类在应用程序启动时执行即可ApplicationProgram.Run();启动前需要确保DB已经开启了SQL Server Agentwindows环境可以通过cmd命令开启net start SQLSERVERAGENTlinux或docker环境可以通过以下命令开启/opt/mssql/bin/mssql-conf set sqlagent.enabled true如果是基础BaseSubscribeT中间基类需要定义成abstract例如关闭监听在应用程序退出时执行即可ApplicationProgram.Close();(四)其他配置框架开源完整框架源码可以去Github上下载https://github.com/a935368322/Kogel.Subscribe.Mssql如有问题也可以加QQ群讨论技术群 710217654
