asp.net core為ihttpclientfactory添加動態(tài)命名配置
比如如何使用ihttpclientfactory動態(tài)添加cer證書
有三種方法推薦方法
- 方法一: 推薦的做法是這樣子
services.addhttpclient("a業(yè)務").configureprimaryhttpmessagehandler(...a業(yè)務證書)
services.addhttpclient("b業(yè)務").configureprimaryhttpmessagehandler(...b業(yè)務證書)
serviceprovider.getservice<ihttpclientfactory>().createclient("a業(yè)務")....
- 方法二:
如果你要完全自定義則可以用 new system.net.http.httpclient(handler)
- 方法三:
在或者用騷操作, 替換配置的方式也可以 邏輯就是實現(xiàn)一個自己的httpclientfactoryoptions, 然后動態(tài)生成它.
get_cert_handler_by_name 是你自己的方法,可以根據任何是否使用區(qū)別業(yè)務名稱a,b,c new 一個handler.
但是要注意, 這樣子所有從serviceprovider獲取httpclient都會走到這個自定義配置類上面, 要做好兼容性.
class myclass : ipostconfigureoptions<httpclientfactoryoptions>
{
public void postconfigure(string name, httpclientfactoryoptions options)
=> options.httpmessagehandlerbuilderactions.add(p => p.primaryhandler = get_cert_handler_by_name(name));
}
//注冊這個服務
services.addsingleton<microsoft.extensions.options.ipostconfigureoptions<microsoft.extensions.http.httpclientfactoryoptions>, myclass>();
上述是一些前情概要, 那么接下來我們就來實現(xiàn)這個需求.
秒想到一個方法, 我們可以直接new httpclient(), 在每一次要使用的時候都直接來一個, 簡單粗暴.
秒想到第二個方法, 又或者用一個dictionary<string,httpclient>根據名字緩存client對象.
但是前者性能是個問題,而且涉及到端口的占用釋放問題, 在調用量稍大的情況下得涼涼, 后者則是有已知的問題httpclient對象沒法感知dns的變更.
其他一些更不靠譜的方法還有: 使用代碼配置方式(services.addhttpclient("callback provider side").configureprimaryhttpmessagehandler())配置所有證書, 還有把所有證書都安裝的本機上并設置為信任證書.
那么能除了上面這些不靠譜的方式(或者說有致命缺陷的方式), 還有靠譜的么, 那當然是有的, 例如運行時的動態(tài)配置實現(xiàn)方案.
所以, 接下來, 我來推薦 2 種方式式,就是我們的ihttpmessagehandlerbuilderfilter和ipostconfigureoptions.
官方有什么推薦么?
針對如何為httpclient對象添加證書, 官方文檔的實現(xiàn)是:使用證書和來自 ihttpclientfactory 的命名 httpclient 實現(xiàn) httpclient 和 使用證書和 httpclienthandler 實現(xiàn) httpclient, 但是在這里顯然沒法解決我們的運行時配置的需求, 但是它給出了一條線索, 那就是命名配置. 它可以為我們的每一個不同的provider提供自定義配置. 只要我們能為每一個不同的provider能提供運行時配置即可, 接下來就是源碼閱讀時間了:
下文中的所有代碼都來自netcore 3.1, 并且僅copy關鍵代碼, 完整代碼可以前往github查看.
ihttpclientfactory.createclient是如何將httpclient創(chuàng)建出來的?
- 每次
createclient出來的都是一個新的httpclient實例 - 在
createhandler中的_activehandlers將為我們緩存我們的handler, 默認是2分鐘(定義在httpclientfactoryoptions.handlerlifetime)- 這里有一個知識點就是如果我的請求剛好在過期時間前一點點獲取到這個緩存的對象,就是有可能我當前的請求還在進行中, 但是2分鐘過去后這個handler就要被回收的. 那官方是如何替我們解決這個可能的bug的呢, 請查看文章cleaning up expired handlers, 我就不贅述了, 關鍵點在于用了一個
weakreference
- 這里有一個知識點就是如果我的請求剛好在過期時間前一點點獲取到這個緩存的對象,就是有可能我當前的請求還在進行中, 但是2分鐘過去后這個handler就要被回收的. 那官方是如何替我們解決這個可能的bug的呢, 請查看文章cleaning up expired handlers, 我就不贅述了, 關鍵點在于用了一個
createhandlerentry方法則是真正的創(chuàng)建以及配置我們的handlers的地方.- 從
iconfiguration獲得一個httpclientfactoryoptions對象 - 應用
ihttpmessagehandlerbuilderfilter - 應用
httpmessagehandlerbuilderactions
- 從
//microsoft.extensions.http.defaulthttpclientfactory
public httpclient createclient(string name)
{
httpclient httpclient = new httpclient(this.createhandler(name), disposehandler: false);
return httpclient;
}
public httpmessagehandler createhandler(string name)
{
activehandlertrackingentry value = this._activehandlers.getoradd(name, this._entryfactory).value;
//_entryfactory可以直接理解為是createhandlerentry方法.它真實的類型是lazy<>(createhandlerentry,lazythreadsafetymode.executionandpublication)的, 也就是并發(fā)安全的調用createhandlerentry.
return value.handler;
}
internal activehandlertrackingentry createhandlerentry(string name)
{
httpclientfactoryoptions options = this._optionsmonitor.get(name);
httpmessagehandlerbuilder requiredservice = provider.getrequiredservice<httpmessagehandlerbuilder>();
requiredservice.name = name;
action<httpmessagehandlerbuilder> action = configure; // 擴展點二 httpclientfactoryoptions.httpmessagehandlerbuilderactions
for (int num = this._filters.length - 1; num >= 0; num--)
{
action = this._filters[num].configure(action); //擴展點一 _filters(構造函數傳入的ienumerable<ihttpmessagehandlerbuilderfilter> filters).
}
action(requiredservice);
lifetimetrackinghttpmessagehandler handler = new lifetimetrackinghttpmessagehandler(requiredservice.build());
return new activehandlertrackingentry(name, handler, servicescope, options.handlerlifetime);
void configure(httpmessagehandlerbuilder b)
{
for (int i = 0; i < options.httpmessagehandlerbuilderactions.count; i++)
{
options.httpmessagehandlerbuilderactions[i](b);
}
}
}
關鍵點代碼就是上面代碼中標記出來的擴展點一 和 擴展點二.
- 擴展點一: 需要注入適當的ihttpmessagehandlerbuilderfilter對象,就可以改寫
requiredservice對象, 也就可以實現(xiàn)我們要的運行時動態(tài)配置了. - 擴展點二: 需要實現(xiàn)自定義的iconfiguration配置, 只要
this._optionsmonitor.get(name)拿到的對象的httpmessagehandlerbuilderactions屬性包含我們相應的改寫代碼即可.
擴展點一的實現(xiàn)
為httpclient的handler增加一個配置的filter, 針對符合的handlerbuilder增加一些自己的改寫邏輯.
我們在用httpclient對象的時候產生的日志("sending http request......","received http response headers after......")就是由這個filter特性注入的. 官方參考代碼:logginghttpmessagehandlerbuilderfilter
個人見解: 覺得在這個擴展點加這個業(yè)務不是特別的符合應用場景, 所以我建議在擴展點二做這個事情.
class myhttpclienthandlerfilter : ihttpmessagehandlerbuilderfilter
{
public action<httpmessagehandlerbuilder> configure(action<httpmessagehandlerbuilder> next)
{
void configure(httpmessagehandlerbuilder builder)
{
next(builder); //一開始就調用next, 這樣我們的整個handlerbuilder的執(zhí)行順序就是依次call _filters, 最后call options.httpmessagehandlerbuilderactions(擴展點二).
if (builder.name.startswith("callbackproviderside-")) //我們可以為這類業(yè)務統(tǒng)一加一個前綴做區(qū)別, 這樣就不會影響其他的httpclient對象了.
{
//builder.primaryhandler= your custom handler. 參考官方文檔的實現(xiàn).
}
}
return configure;
}
}
//然后在di容器中注入我們的filter.
servicecollection.addsingleton<ihttpmessagehandlerbuilderfilter,myhttpclienthandlerfilter>();
擴展點二的實現(xiàn)
class myhttpclientcustomconfigure : ipostconfigureoptions<httpclientfactoryoptions>
{
public void postconfigure(string name, httpclientfactoryoptions options)
{
if (name.startswith("callbackproviderside-")) //我們可以為這類業(yè)務統(tǒng)一加一個前綴做區(qū)別, 這樣就不會影響其他的httpclient對象了.
{
options.httpmessagehandlerbuilderactions.add(p =>
{
//p.primaryhandler= your custom handler. 參考官方文檔的實現(xiàn).
});
}
}
}
//然后在di容器中注入我們的這個配置擴展類.
servicecollection.addsingleton<microsoft.extensions.options.ipostconfigureoptions<microsoft.extensions.http.httpclientfactoryoptions>, myhttpclientcustomconfigure>();
為什么這里注入的類型是microsoft.extensions.options.ipostconfigureoptions<microsoft.extensions.http.httpclientfactoryoptions>, 是因為optionsfactory它的構造函數需要的就是這個. 至于有關configuration系統(tǒng)的擴展和源代碼在這里就不在這里展開了.
使用
至于用它就簡單了
var factory = serviceprovider.getservice<ihttpclientfactory>();
var httpclientforbaidu = factory.createclient("callbackproviderside-baidu");
var httpclientforcnblogs = factory.createclient("callbackproviderside-cnblogs");
總結一下
這樣子, 我們的這個運行時動態(tài)配置httpclient就算完成了, 我也輕輕松松又水了一篇文章.
另外,有關ihttpclientfactory背后的故事可以查看文章exploring the code behind ihttpclientfactory in depth, 很完整的流程圖在配上代碼, 把它講解的清清楚楚.
以上就是asp.net core為ihttpclientfactory添加動態(tài)命名配置的詳細內容，更多關于asp.net core 添加動態(tài)命名配置的資料請關注碩編程其它相關文章！
C++實戰(zhàn)