个人中心
文章发布
退出
作者热门文章
- Java锁的逻辑（结合对象头和ObjectMonitor）
- 还在用饼状图？来瞧瞧这些炫酷的百分比可视化新图形（附代码实现）⛵
- 自动注册实体类到EntityFrameworkCore上下文，并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
34
4
相信巨硬，我们便一直硬。Net版本到现在已经出了7了，8也已经在预览版了，相信在一个半月就会正式发布，其中也有很多拭目以待的新功能了，不仅仅有Apm和Tap的结合，TaskToAscynResult，以及UnsafeAccessor用来获取私有变量，性能比反射,EMIT更高，还有针对AsyncLocal封装的IAsyncContext，IAsyncState，用来存异步上下文的一些数据，当然了，最让我期待的还是自带了一个OpenFeign，在看新增的东西的时候，其他的都觉得一般般，个人觉得哈，当看到这个AutoClient新增的包的时候，好奇心的驱使下，我点进去看了一下，哇，官网终于出这玩意了，使用简单，根据特性，然后使用Sg来生成我们对应的实现从而我们只需要定义一个接口，打上特性，就可以生成一个对应的代理类，调用远程Api接口，太令人心动，为此特地升级了VS，下载了Net8，体验新功能，接下来，我们就看看他的使用案例。附官网链接: https://learn.microsoft.com/zh-cn/dotnet/api/microsoft.extensions.http.autoclient.autoclientattribute?view=dotnet-plat-ext-8.0 。
在使用自带的OpenFeign的时候，我们还需要下载一个扩展包 Microsoft.Extensions.Http.AutoClient，当然还有 Microsoft.Extensions.Http的扩展包了，接下来我们定义一个接口，IBussiness，打上AutoClient特性，第一个参数是我们在注入Httpclient的时候，给的名字，我这里叫TestApi，这里会根据使用了AutoClient特性自定生成一个BussIness的类，在下图可以看到，自动生成了一个AutoClient.g.cs文件，里面的类就是Bussiness，其中包括了我们的TestPost方法以及路由信息，在上面的代码中，我们使用了Post特性，代表我们这个是Post请求，以及方法参数限制必须有一个CancellationToken，这个Post里面的内容，就是我另外一个项目种的接口地址.
builder.Services.AddHttpClient("TestApi",s=>s.BaseAddress=new Uri(" http://localhost:5062"));
[AutoClient(
"
TestApi
"
)]
public
interface
IBussiness
{
[Post(
"
/Test/TestPost
"
)]
public
Task<
string
>
TestPost(CancellationToken cancellationToken);
}
。
//
<auto-generated/>
#nullable enable
#pragma
warning disable CS1591
//
Compensate for
https://github.com/dotnet/roslyn/issues/54103
namespace
WebApplication1.Api
{
[
global
::System.CodeDom.Compiler.GeneratedCodeAttribute(
"
Microsoft.Gen.AutoClient
"
,
"
8.0.0.0
"
)]
public
class
Bussiness : IBussiness
{
private
static
class
Statics
{
public
static
readonly
global
::System.Net.Http.Headers.MediaTypeHeaderValue ApplicationJsonHeader =
new
(
"
application/json
"
)
{
CharSet
=
global
::System.Text.Encoding.UTF8.WebName
};
public
static
readonly
global
::System.Net.Http.Headers.MediaTypeHeaderValue TextPlainHeader =
new
(
"
text/plain
"
)
{
CharSet
=
global
::System.Text.Encoding.UTF8.WebName
};
public
static
readonly
global
::System.Uri UriTestPost =
new
(
"
/Test/TestPost
"
,
global
::System.UriKind.Relative);
public
static
readonly
global
::Microsoft.Extensions.Http.Telemetry.RequestMetadata RequestMetadataTestPost =
new
()
{
DependencyName
=
"
Bussiness
"
,
RequestName
=
"
TestPost
"
,
RequestRoute
=
"
/Test/TestPost
"
};
}
private
readonly
global
::System.Net.Http.HttpClient _httpClient;
private
readonly
global
::Microsoft.Extensions.Http.AutoClient.AutoClientOptions _autoClientOptions;
public
Bussiness(
global
::System.Net.Http.HttpClient httpClient,
global
::Microsoft.Extensions.Http.AutoClient.AutoClientOptions autoClientOptions)
{
_httpClient
=
httpClient;
_autoClientOptions
=
autoClientOptions;
}
public
async
global
::System.Threading.Tasks.Task<
string
> TestPost(
global
::System.Threading.CancellationToken cancellationToken)
{
var
httpRequestMessage =
new
global
::System.Net.Http.HttpRequestMessage()
{
Method
=
global
::System.Net.Http.HttpMethod.Post,
RequestUri
=
Statics.UriTestPost,
};
try
{
global
::Microsoft.Extensions.Telemetry.TelemetryExtensions.SetRequestMetadata(httpRequestMessage, Statics.RequestMetadataTestPost);
return
await
SendRequest<
string
>(
"
Bussiness
"
, Statics.RequestMetadataTestPost.RequestRoute, httpRequestMessage, cancellationToken)
.ConfigureAwait(
false
);
}
finally
{
httpRequestMessage.Dispose();
}
}
private
async
global
::System.Threading.Tasks.Task<TResponse> SendRequest<TResponse>
(
string
dependencyName,
string
path,
global
::System.Net.Http.HttpRequestMessage httpRequestMessage,
global
::System.Threading.CancellationToken cancellationToken)
where
TResponse :
class
{
var
response =
await
_httpClient.SendAsync(httpRequestMessage, cancellationToken).ConfigureAwait(
false
);
if
(
typeof
(TResponse) ==
typeof
(
global
::System.Net.Http.HttpResponseMessage))
{
return
(response
as
TResponse)!
;
}
try
{
if
(!
response.IsSuccessStatusCode)
{
var
error =
await
global
::Microsoft.Extensions.Http.AutoClient.AutoClientHttpError.CreateAsync(response, cancellationToken).ConfigureAwait(
false
);
throw
new
global
::Microsoft.Extensions.Http.AutoClient.AutoClientException(
global
::System.FormattableString.Invariant($
"
The '{dependencyName}' HTTP client failed with '{response.StatusCode}' status code.
"
), path, error);
}
if
(
typeof
(TResponse) ==
typeof
(
string
))
{
#if
NET5_0_OR_GREATER
var
rawContent =
await
response.Content.ReadAsStringAsync(cancellationToken).ConfigureAwait(
false
);
#else
cancellationToken.ThrowIfCancellationRequested();
var
rawContent =
await
response.Content.ReadAsStringAsync().ConfigureAwait(
false
);
#endif
return
(rawContent
as
TResponse)!
;
}
var
mediaType = response.Content.Headers.ContentType?
.MediaType;
if
(mediaType ==
"
application/json
"
)
{
var
deserializedResponse =
await
global
::System.Net.Http.Json.HttpContentJsonExtensions.ReadFromJsonAsync<TResponse>
(response.Content, _autoClientOptions.JsonSerializerOptions, cancellationToken)
.ConfigureAwait(
false
);
if
(deserializedResponse ==
null
)
{
var
error =
await
global
::Microsoft.Extensions.Http.AutoClient.AutoClientHttpError.CreateAsync(response, cancellationToken).ConfigureAwait(
false
);
throw
new
global
::Microsoft.Extensions.Http.AutoClient.AutoClientException(
global
::System.FormattableString.Invariant($
"
The '{dependencyName}' REST API failed to deserialize response.
"
), path, error);
}
return
deserializedResponse;
}
var
err =
await
global
::Microsoft.Extensions.Http.AutoClient.AutoClientHttpError.CreateAsync(response, cancellationToken).ConfigureAwait(
false
);
throw
new
global
::Microsoft.Extensions.Http.AutoClient.AutoClientException(
global
::System.FormattableString.Invariant($
"
The '{dependencyName}' REST API returned an unsupported content type ('{mediaType}').
"
), path, err);
}
finally
{
response.Dispose();
}
}
}
[
global
::System.CodeDom.Compiler.GeneratedCodeAttribute(
"
Microsoft.Gen.AutoClient
"
,
"
8.0.0.0
"
)]
public
static
class
AutoClientsExtensions
{
public
static
global
::Microsoft.Extensions.DependencyInjection.IServiceCollection AddBussiness(
this
global
::Microsoft.Extensions.DependencyInjection.IServiceCollection services)
{
return
services.AddBussiness(_ =>
{ });
}
public
static
global
::Microsoft.Extensions.DependencyInjection.IServiceCollection AddBussiness(
this
global
::Microsoft.Extensions.DependencyInjection.IServiceCollection services,
global
::System.Action<
global
::Microsoft.Extensions.Http.AutoClient.AutoClientOptions>
configureOptions)
{
global
::Microsoft.Extensions.DependencyInjection.OptionsServiceCollectionExtensions.AddOptionsWithValidateOnStart<
global
::Microsoft.Extensions.Http.AutoClient.AutoClientOptions,
global
::Microsoft.Extensions.Http.AutoClient.AutoClientOptionsValidator>(services,
"
Bussiness
"
).Configure(configureOptions);
global
::Microsoft.Extensions.DependencyInjection.Extensions.ServiceCollectionDescriptorExtensions.TryAddSingleton<IBussiness>(services, provider =>
{
var
httpClient =
global
::Microsoft.Extensions.DependencyInjection.ServiceProviderServiceExtensions.GetRequiredService<
global
::System.Net.Http.IHttpClientFactory>(provider).CreateClient(
"
TestApi
"
);
var
autoClientOptions =
global
::Microsoft.Extensions.DependencyInjection.ServiceProviderServiceExtensions.GetRequiredService<
global
::Microsoft.Extensions.Options.IOptionsMonitor<
global
::Microsoft.Extensions.Http.AutoClient.AutoClientOptions>>(provider).Get(
"
Bussiness
"
);
return
new
Bussiness(httpClient, autoClientOptions);
});
return
services;
}
}
}
。
下面这段代码，是我另一个项目接口的代码，可以看到，路由是Test，方法的路由是TestPost，返回了一个字符串true，因为，在使用AutoClient的时候，返回类型必须是引用类型，接下来，我们调用一下测试看看，在返回的结果中，我们可以看到返回了我们在另一个项目中返回的结果，true，同时，AutoClient还支持Get,Patch，Delete，Get，Put，Body（标记是在Body中），Header，Query等诸多特性，就是一个c#版本的OpenFeign，简直爽的不要不要的.
[Route(
"
Test
"
)]
public
class
TestController : ControllerBase
{
public
TestController()
{
}
[HttpPost(
"
TestPost
"
)]
public
Task<
string
>
TestPost()
{
return
Task.FromResult(
"
true
"
);
}
}
。
今天就要开始十月一假期了，后续节后来了，会持续带来新增api的一些玩法，包括IAsyncContext，还有其他的在等待探索，欢迎大家关注.
最后此篇关于【c#版本Openfeign】Net8自带OpenFeign实现远程接口调用的文章就讲到这里了,如果你想了解更多关于【c#版本Openfeign】Net8自带OpenFeign实现远程接口调用的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
34
4
0
无法使用 Hive 版本 1.1.0 HBase 版本 0.94.8 和 hadoop 版本 2.7.0 从 hive 创建 Hbase 表 hive (default)> CREATE TABLE
我试图为 electron app 创建可执行文件但面临这个问题 Unable to determine Electron version. Please specify an Electron ve
我正在尝试让自适应阈值在 python 绑定(bind)到 opencv 中工作(swig 一个 - 无法让 opencv 2.0 工作，因为我正在使用 beagleboard 因为交叉编译还没有工作
我一直在 linux 机器上使用 JMeter，在命令行下使用了一段时间。工作正常。 今天，我在 Windows 机器(新客户端等)上尝试了它，它确实可以工作，但在控制台窗口中输出有很大不同。 Lin
在我的编码环境中，我通常使用最新版本的 Java 和 Eclipse。当我编写源代码时，我不会注意我使用的 API 方法或类是否向后兼容旧版本的 Java 或 Eclipse。在 javadoc 中存
问题是关于版本的特定组合，但更普遍。 我刚刚从 Kubuntu 12.04 升级到 14.04。现在，当我想编译 CUDA 代码(使用 CUDA 6.5)时，我得到: #error -- unsupp
我目前正在对我的一些应用程序进行沙箱处理，看来我必须删除一些功能才能满足 Mac App Store 沙箱(和其他)规则。 显然用户不会因为失去功能而感到高兴，我担心他们不会指责苹果制定了愚蠢的规则，
我用 flash 和 js 版本创建了一个动画横幅。 是否可以检测低于版本 9 的 ie 版本，然后提供 Flash 横幅，否则提供 js 横幅。 最佳答案 您可以使用条件注释来检测 IE 版本
我有一个处理不同位置的数据库的应用程序，我想检查这些数据库是否使用 Firebird 2.5 或更高版本打开。我们最近从 Firebird 2.0 迁移到了 2.5，我们有很多数据库可以响应 sele
我正在开发一个应用程序，我使用托管在我的服务器上的 Java 和 Jersey 构建了后端部分。我在服务器上使用 Tomcat7 来调用 Web 服务。 我以前有一台安装了 Ubuntu 的计算机，我
我可以使用 GetVersionEx() 函数来获取 Windows 版本，但是这个函数将返回一个数字而不是一个字符串。但是没有问题，因为我可以将数字转换为字符串，例如: if (osvi.dwMaj
我已经在我的系统中安装了 Anaconda 2 & 3。 Anaconda 2 包含 python 2.7 & Anaconda 3 包含 python 3.6。 我需要使用命令提示符运行我的 pyt
我正在尝试构建一个 Android 项目，但发生了以下错误 Error:(10, 1) A problem occurred evaluating project ':app'. > Failed t
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗？ 更新问题，使其只关注一个问题 editing this post . 关闭 4 年前。 Improve this qu
在降级我的 GCC 之前，我想知道是否有办法确定我的机器中的哪些程序/框架或依赖项会中断，以及是否有更好的方法来执行 openpose 安装？ (例如，在 CMake 中更改某些内容) 有没有办法在不
我已经在终端的代码sudo apt-get install Shadowsocks-qt5中安装了Shadowsocks-Qt5，然后我可以通过搜索找到启动图标，但是它当我点击图标时打不开。然后我尝试
在网络上找到的文档说，MLLP V2(第 2 版)是用于传输 HL7 版本 3 内容的所有消息传输协议(protocol)的要求。似乎 MLLP 第 2 版主要用于 HL7 第 3 版。 我们可以/应
我正在使用带有 selinium webdriver 的 Protractor 。我的chromeDriver版本是78.0.1，chrome版本是78.0.3904.97。两个版本都匹配，应该不会有
我正在按照教程设置 mysql 数据库并做一些事情。我无法找到数据库资源管理器。我读了很多，但在 Window->show View-> Dataxxx 或右侧上部选项卡中无法正常工作。 最佳答案 从
我已经在 KDE 桌面上安装了 Anaconda 2.0.1。当我运行 python 并看到所有已安装的模块时，我收到此消息“无法将不兼容的 Qt 库(版本 0x40801)与该库(版本 0x4080
我是一名优秀的程序员,十分优秀！