- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
相信巨硬,我们便一直硬。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的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
在 openFeign 未出现前,Spring 提供了 RestTemplate 作为远程服务调用的客户端,提供了多种便捷访问远程 Http 服务的方法,能够大大提高客户端的编写效率。由于文章内容会使
在微服务开发中SpringCloud全家桶集成了OpenFeign用于服务调用,SpringCloud的OpenFeign使用SpringMVCContract来解析OpenFeign的接口定义。
我在 Spring Boot 中使用 OpenFeign 客户端而不使用 Ribbon 或 Eureka。我创建了一个自定义错误解码器,它按预期处理响应错误,但连接拒绝错误似乎绕过了我的自定义解码器。
大家好,我是三友~~ 前几天有个大兄弟问了我一个问题,注册中心要集成SpringCloud,想实现SpringCloud的负载均衡,需要实现哪些接口和规范。
我有一个 OpenFeign 客户端,设置如下: @FeignClient(name = "myService", qualifier = "myServiceClient", url = "${my
本篇文章涉及底层设计以及原理,以及问题定位,比较深入,篇幅较长,所以拆分成上下两篇: 上:问题简单描述以及 Spring Cloud RefreshScope 的原理 下:当前 s
我正在使用 swagger-codegen 为我的 Feign Client 生成界面。 但是 swagger-codegen 生成这些方法: Optional getObjectMapper();
我正在使用 spring Cloud openFeign 来从 service#1 向 service#2 发出请求 当我使用restTemplate时,我可以在jaeger跟踪中正确地看到2个请求。
简介 我最近使用了 netflix feign 和 ribbon,这非常有用。 一个例子是: @FeignClient(name = "ldap-proxy") public interface Ld
有什么区别: spring-cloud-starter-openfeign ( https://github.com/spring-cloud/spring-cloud-openfeign ) 和 s
我正在使用 Spring Boot 创建基于休息的服务。一切正常。 现在我添加了以下依赖项 org.springframework.cloud
我正在调用一个 API,它将某些 HttpHeaders 列入黑名单,包括 Content-Length ,它似乎是由 spring-openfeign 下的 HttpClient 预设的。为了正确接
我在 spring 和 openfeign 方面遇到问题,我认为你可以帮助我。 我有一个 pom 文件如下: 4.0.0 xx.yyy component 1.0.
OpenApi documentation说它支持千分尺。集成如何工作?除了这个小文档,我找不到任何东西。 我在 Spring Boot 应用程序中有一个 FeignClient @FeignClie
当我尝试实现 ErrorDecoder 来解码 feign 异常时,我发现 response.body() 中的流已关闭,因此当我尝试读取该流时并转换为字符串,它抛出java.io.IOExcepti
当尝试将 feign-httpclient 与 Spring-cloud-starter-openfeign 一起使用时,我收到 SSL 握手异常,而如果我不使用,相同的代码可以工作feign-htt
我在 eclipse java 中有 pom.xml,用于在 java 中构建简单的 Rest Web 服务,但是该依赖项显示错误,我已经尝试并且添加版本和更新项目在依赖项中仍然存在错误,我该如何修复
语境 我有一个 spring boot (version 2.2.6.RELEASE) web 项目。 从这个 Web 应用程序(我称之为“APP1”)我想使用来自另一个 Web 应用程序的 PATC
我有一个带有以下假客户的项目 @FeignClient(name = "name", url = "${tokenService}") public interface TokenService {
目标:从 Spring Boot 1.x (webMvc) 迁移到版本 2 (webFlux),并将 Spring Cloud Edgware SR2 迁移到 FinchleyM8(等待发布版本)。
我是一名优秀的程序员,十分优秀!