一、多樣輸出支持

　　CanalSharp.AspNetCore是一個(gè)基于CanalSharp的適用于ASP.NET Core的一個(gè)后臺(tái)任務(wù)組件，它可以隨著ASP.NET Core實(shí)例的啟動(dòng)而啟動(dòng)，目前采用輪詢的方式對(duì)Canal Server進(jìn)行監(jiān)聽，獲得MySql行更改（RowChange）后寫入MySql指定的記錄表中。在此次更新中，可以支持寫入MongoDB數(shù)據(jù)庫(kù)了，換句話說(shuō)，可以支持MySql或MongoDB二選一的輸出方式了。

　　這個(gè)項(xiàng)目的GitHub地址為：https://github.com/XiLife-OSPC/CanalSharp.AspNetCore

二、新的配置內(nèi)容

　　為了同時(shí)支持MySql及MongoDB，請(qǐng)更新CanalSharp.AspNetCore至0.0.4版本：

　　然后，如果要輸出到MySql請(qǐng)更新以下配置到appSettings.json：

"Canal": { "Enabled": true, "LogSource": "Core.Product.Canal", "ServerIP": "192.168.16.190", // Canal-Server IP "ServerPort": 8001, // Canal-Server 端口號(hào) "Destination": "products", // 與Canal-Server中配置的destination保持一致 "Filter": "xdp_products_dev\\..*", // 與Canal-Server中配置的filter保持一致 "SleepTime": 100, // 空閑時(shí)間睡眠時(shí)間 "BufferSize": 2048, // 如果涉及到更改的數(shù)據(jù)量較大請(qǐng)將BufferSize設(shè)大一些 "Output": { "MySql":{ "ConnStr": "Server=192.168.16.150;Port=3306;Database=products_dev;Uid=dev;Pwd=xdp" // 要輸出的日志記錄表所在的MySql連接字符串 } } }

　　如果要輸出到MongoDB請(qǐng)更新以下配置到appSettings.json：

"Canal": { "Enabled": true, "LogSource": "Core.Product.Canal", "ServerIP": "192.168.16.190", // Canal-Server IP "ServerPort": 8001, // Canal-Server 端口號(hào) "Destination": "products", // 與Canal-Server中配置的destination保持一致 "Filter": "xdp_products_dev\\..*", // 與Canal-Server中配置的filter保持一致 "SleepTime": 100, // 空閑時(shí)間睡眠時(shí)間 "BufferSize": 2048, // 如果涉及到更改的數(shù)據(jù)量較大請(qǐng)將BufferSize設(shè)大一些 "Output": { "Mongo": { "ConnStr": "mongodb://192.168.16.150:27017", "DataBase": "xdp_behaviors_dev" } } }

　　就這點(diǎn)配置文件的改動(dòng)，其他的無(wú)需改動(dòng)。

　　具體的Sample示例可以參考這里：CanalSharp.AspNetCore.Sample

三、效果演示

　　當(dāng)在指定要監(jiān)聽的數(shù)據(jù)庫(kù)對(duì)某張表的某行數(shù)據(jù)進(jìn)行Update或Delete操作后，又或者進(jìn)行Insert行操作后。

3.1 MySql

　　如果選擇輸出到MySql數(shù)據(jù)庫(kù)，那么canal.logs表（該表會(huì)自動(dòng)創(chuàng)建）會(huì)自動(dòng)記錄變更的記錄數(shù)據(jù)如下圖所示：

PS：INSERT操作會(huì)記錄新增的數(shù)據(jù)行數(shù)據(jù)到CurrentValue列， DELETE操作會(huì)記錄刪除的數(shù)據(jù)行數(shù)據(jù)到PreviousValue列， UPDATE操作則會(huì)記錄修改前PreviousValue和修改后的值CurrentValue。

3.2 MongoDB

　　如果選擇輸出到MongoDB，那么會(huì)自動(dòng)記錄變更數(shù)據(jù)到你指定的數(shù)據(jù)庫(kù)中的changelogs中如下圖：

　　就這樣吧，Code仍然很亂，也沒時(shí)間去優(yōu)化了，先就這樣將就用吧。

總結(jié)

以上是生活随笔為你收集整理的CanalSharp.AspNetCore v0.0.4-支持输出到MongoDB的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。