码迷,mamicode.com
首页 > 其他好文 > 详细

eureka注册原理

时间:2020-04-13 00:31:29      阅读:89      评论:0      收藏:0      [点我收藏+]

标签:pac   app   writer   exec   nbsp   bsp   RKE   send   ica   

https://www.jianshu.com/p/84d0b7eea882
eureka注册原理:
注册地址:POST 对象com.netflix.appinfo.InstanceInfo
http://localhost:8761/eureka/apps/HELLO-SERVICE

{Accept-Encoding=[gzip], Content-Type=[application/json], Accept=[application/json], DiscoveryIdentity-Name=[DefaultClient], DiscoveryIdentity-Version=[1.4], DiscoveryIdentity-Id=[192.168.1.106]}

AbstractJerseyEurekaHttpClient.register
ApacheHttpClient4Handler.handle

HttpRequestExecutor.doSendRequest

 


Daemon Thread [DiscoveryClient-HeartbeatExecutor-1] (Suspended (breakpoint at line 48 in AbstractJerseyEurekaHttpClient))
JerseyApplicationClient(AbstractJerseyEurekaHttpClient).register(InstanceInfo) line: 48
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
MetricsCollectingEurekaHttpClient.execute(RequestExecutor<R>) line: 73
MetricsCollectingEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
RedirectingEurekaHttpClient.executeOnNewServer(RequestExecutor<R>, AtomicReference<EurekaHttpClient>) line: 118
RedirectingEurekaHttpClient.execute(RequestExecutor<R>) line: 79
RedirectingEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
RetryableEurekaHttpClient.execute(RequestExecutor<R>) line: 119
RetryableEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
SessionedEurekaHttpClient.execute(RequestExecutor<R>) line: 77
SessionedEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
CloudEurekaClient(DiscoveryClient).register() line: 815
CloudEurekaClient(DiscoveryClient).renew() line: 837
DiscoveryClient$HeartbeatThread.run() line: 1396
Executors$RunnableAdapter<T>.call() line: 511
FutureTask<V>.run() line: 266
ThreadPoolExecutor.runWorker(ThreadPoolExecutor$Worker) line: 1149
ThreadPoolExecutor$Worker.run() line: 624
Thread.run() line: 748


Daemon Thread [DiscoveryClient-InstanceInfoReplicator-0] (Suspended)
HttpRequestExecutor.doSendRequest(HttpRequest, HttpClientConnection, HttpContext) line: 238
HttpRequestExecutor.execute(HttpRequest, HttpClientConnection, HttpContext) line: 123
DefaultRequestDirector.tryExecute(RoutedRequest, HttpContext) line: 686
DefaultRequestDirector.execute(HttpHost, HttpRequest, HttpContext) line: 488
DefaultHttpClient(AbstractHttpClient).doExecute(HttpHost, HttpRequest, HttpContext) line: 884
DefaultHttpClient(CloseableHttpClient).execute(HttpHost, HttpRequest) line: 117
DefaultHttpClient(CloseableHttpClient).execute(HttpHost, HttpRequest) line: 55
ApacheHttpClient4Handler.handle(ClientRequest) line: 173
GZIPContentEncodingFilter.handle(ClientRequest) line: 123
EurekaIdentityHeaderFilter.handle(ClientRequest) line: 27
ApacheHttpClient4(Client).handle(ClientRequest) line: 652
WebResource.handle(Class<T>, ClientRequest) line: 682
WebResource.access$200(WebResource, Class, ClientRequest) line: 74
WebResource$Builder.post(Class<T>, Object) line: 570
JerseyApplicationClient(AbstractJerseyEurekaHttpClient).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
MetricsCollectingEurekaHttpClient.execute(RequestExecutor<R>) line: 73
MetricsCollectingEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
RedirectingEurekaHttpClient.executeOnNewServer(RequestExecutor<R>, AtomicReference<EurekaHttpClient>) line: 118
RedirectingEurekaHttpClient.execute(RequestExecutor<R>) line: 79
RedirectingEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
RetryableEurekaHttpClient.execute(RequestExecutor<R>) line: 119
RetryableEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
SessionedEurekaHttpClient.execute(RequestExecutor<R>) line: 77
SessionedEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
CloudEurekaClient(DiscoveryClient).register() line: 815
InstanceInfoReplicator.run() line: 104
InstanceInfoReplicator$1.run() line: 88
Executors$RunnableAdapter<T>.call() line: 511
ScheduledThreadPoolExecutor$ScheduledFutureTask<V>(FutureTask<V>).run() line: 266
ScheduledThreadPoolExecutor$ScheduledFutureTask<V>.access$201(ScheduledThreadPoolExecutor$ScheduledFutureTask) line: 180
ScheduledThreadPoolExecutor$ScheduledFutureTask<V>.run() line: 293
ScheduledThreadPoolExecutor(ThreadPoolExecutor).runWorker(ThreadPoolExecutor$Worker) line: 1149
ThreadPoolExecutor$Worker.run() line: 624
Thread.run() line: 748


Daemon Thread [DiscoveryClient-InstanceInfoReplicator-0] (Suspended)
EurekaJacksonCodec.writeTo(T, OutputStream) line: 191
CodecWrappers$LegacyJacksonJson.encode(T, OutputStream) line: 304
DiscoveryJerseyProvider.writeTo(Object, Class, Type, Annotation[], MediaType, MultivaluedMap, OutputStream) line: 135
RequestWriter$RequestEntityWriterImpl.writeRequestEntity(OutputStream) line: 231
ApacheHttpClient4Handler$2.writeTo(OutputStream) line: 289
EntityEnclosingRequestWrapper$EntityWrapper(HttpEntityWrapper).writeTo(OutputStream) line: 94
EntityEnclosingRequestWrapper$EntityWrapper.writeTo(OutputStream) line: 112
EntitySerializer.serialize(SessionOutputBuffer, HttpMessage, HttpEntity) line: 118
DefaultClientConnection(AbstractHttpClientConnection).sendRequestEntity(HttpEntityEnclosingRequest) line: 263
BasicPooledConnAdapter(AbstractClientConnAdapter).sendRequestEntity(HttpEntityEnclosingRequest) line: 241
HttpRequestExecutor.doSendRequest(HttpRequest, HttpClientConnection, HttpContext) line: 238
HttpRequestExecutor.execute(HttpRequest, HttpClientConnection, HttpContext) line: 123
DefaultRequestDirector.tryExecute(RoutedRequest, HttpContext) line: 686
DefaultRequestDirector.execute(HttpHost, HttpRequest, HttpContext) line: 488
DefaultHttpClient(AbstractHttpClient).doExecute(HttpHost, HttpRequest, HttpContext) line: 884
DefaultHttpClient(CloseableHttpClient).execute(HttpHost, HttpRequest) line: 117
DefaultHttpClient(CloseableHttpClient).execute(HttpHost, HttpRequest) line: 55
ApacheHttpClient4Handler.handle(ClientRequest) line: 173
GZIPContentEncodingFilter.handle(ClientRequest) line: 123
EurekaIdentityHeaderFilter.handle(ClientRequest) line: 27
ApacheHttpClient4(Client).handle(ClientRequest) line: 652
WebResource.handle(Class<T>, ClientRequest) line: 682
WebResource.access$200(WebResource, Class, ClientRequest) line: 74
WebResource$Builder.post(Class<T>, Object) line: 570
JerseyApplicationClient(AbstractJerseyEurekaHttpClient).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
MetricsCollectingEurekaHttpClient.execute(RequestExecutor<R>) line: 73
MetricsCollectingEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
RedirectingEurekaHttpClient.executeOnNewServer(RequestExecutor<R>, AtomicReference<EurekaHttpClient>) line: 118
RedirectingEurekaHttpClient.execute(RequestExecutor<R>) line: 79
RedirectingEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
RetryableEurekaHttpClient.execute(RequestExecutor<R>) line: 119
RetryableEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
EurekaHttpClientDecorator$1.execute(EurekaHttpClient) line: 59
SessionedEurekaHttpClient.execute(RequestExecutor<R>) line: 77
SessionedEurekaHttpClient(EurekaHttpClientDecorator).register(InstanceInfo) line: 56
CloudEurekaClient(DiscoveryClient).register() line: 815
InstanceInfoReplicator.run() line: 104
InstanceInfoReplicator$1.run() line: 88
Executors$RunnableAdapter<T>.call() line: 511
ScheduledThreadPoolExecutor$ScheduledFutureTask<V>(FutureTask<V>).run() line: 266
ScheduledThreadPoolExecutor$ScheduledFutureTask<V>.access$201(ScheduledThreadPoolExecutor$ScheduledFutureTask) line: 180
ScheduledThreadPoolExecutor$ScheduledFutureTask<V>.run() line: 293
ScheduledThreadPoolExecutor(ThreadPoolExecutor).runWorker(ThreadPoolExecutor$Worker) line: 1149
ThreadPoolExecutor$Worker.run() line: 624
Thread.run() line: 748

eureka注册原理

标签:pac   app   writer   exec   nbsp   bsp   RKE   send   ica   

原文地址:https://www.cnblogs.com/yaoyu1983/p/12688656.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!