当前位置: 首页 > news >正文

下载的网站模板如何安装学网站开发容易吗

下载的网站模板如何安装,学网站开发容易吗,pexels免费素材网站,wordpress 分页 未找到页面背景 Skywalking默认场景下#xff0c;Tracing对于消息队列的发送场景#xff0c;无法将TraceId传递到下游消费者#xff0c;但对于微服务场景下#xff0c;是有大量消息队列的业务场景的#xff0c;这显然无法满足业务预期。 解决方案 Skywalking的官方社区中#xf…背景 Skywalking默认场景下Tracing对于消息队列的发送场景无法将TraceId传递到下游消费者但对于微服务场景下是有大量消息队列的业务场景的这显然无法满足业务预期。 解决方案 Skywalking的官方社区中有用户提出了该场景问题Skywalking在补充工具包中提供了对Kafka的tracing支持。 代码实现 dependencygroupIdorg.apache.skywalking/groupIdartifactIdapm-toolkit-kafka/artifactIdversion${skywalking.version}/version/dependency对于该工具包默认情况下是针对KafkaTemplate进行trace即如果使用KafkaTemplate发送消息代码层面无需做任何改动。 如果没有使用KafkaTemplate的场景toolkit也提供的了注解的支持 public class ConsumerThread2 extends Thread {Overridepublic void run() {Properties consumerProperties new Properties();//...consumerProperties.put()KafkaConsumerString, String consumer new KafkaConsumer(consumerProperties);consumer.subscribe(topicPattern, new NoOpConsumerRebalanceListener());while (true) {if (pollAndInvoke(consumer)) break;}consumer.close();}KafkaPollAndInvokeprivate boolean pollAndInvoke(KafkaConsumerString, String consumer) {try {Thread.sleep(1000);} catch (InterruptedException e) {}ConsumerRecordsString, String records consumer.poll(100);if (!records.isEmpty()) {OkHttpClient client new OkHttpClient.Builder().build();Request request new Request.Builder().url(http://localhost:8080/kafka-scenario/case/kafka-thread2-ping).build();Response response null;try {response client.newCall(request).execute();} catch (IOException e) {}response.body().close();return true;}return false;} }异步线程Tracing 对于Kafka消息的发送经常会配合异步线程池的场景使用Tracing的基本原理是基于ThreadLocal进行实现的那么对于异步场景是会丢失TraceId通常的解决方式是需要手动将主线程的TraceId手动赋值给子线程但这种方式需要手动代码侵入并不友好。 幸运的是Skywalking的toolkit中提供了对于异步线程tracing的支持。 dependencygroupIdorg.apache.skywalking/groupIdartifactIdapm-toolkit-trace/artifactIdversion${skywalking.version}/version /dependency推荐用法 ExecutorService executorService Executors.newFixedThreadPool(1); executorService.execute(RunnableWrapper.of(new Runnable() {Override public void run() {//your code} }));或者 TraceCrossThreadpublic static class MyCallableString implements CallableString {Overridepublic String call() throws Exception {return null;}} ...ExecutorService executorService Executors.newFixedThreadPool(1);executorService.submit(new MyCallable());PS事实上RunnableWrapper也是基于TraceCrossThread实现。 相关文档 https://skywalking.apache.org/docs/skywalking-java/v8.16.0/en/setup/service-agent/java-agent/application-toolkit-kafka/ https://skyapm.github.io/document-cn-translation-of-skywalking/zh/6.1.0/setup/service-agent/java-agent/Application-toolkit-trace-cross-thread.html https://blog.51cto.com/knifeedge/5268667 https://blog.csdn.net/lijunwyf/article/details/107954543
http://www.pierceye.com/news/693132/

相关文章:

  • 强生网站还要怎样做衡水网站推广的网络公司
  • 茂名建站公司南通长城建设集团有限公司网站
  • 网络平台怎么建立网站吗做暧暧视频网站安全吗
  • 免费域名x网站网站前期准备工作
  • 陕西网站建设公司排名智能优化网站
  • 做瞹瞹网站萍乡做网站的公司有哪些
  • 网站建设的类型有几种wordpress搜索返回页面内容
  • 建设网站备案与不备案区别招远建网站首选公司
  • 四川住房和城乡建设厅网站三类人员软文网站备案如何查询
  • 个人与企业签订网站开发合同网页制作教程实例
  • 做网站遇到竞争对手怎么办wordpress中文版邮件发送
  • 美橙互联旗下网站渐变网站
  • 做网站域名需要在哪里备案微信答题小程序
  • 购物网站页面布局个人站长做导航网站
  • wordpress 增强编辑器网站暂时关闭 seo
  • 重庆网站设计开发培训广西省住房和城乡建设厅官网
  • 购物网站模板免费下载网站排名快速提升工具
  • 中山制作网站的公司滨江区网站开发公司
  • 申请建设工作网站的函酒店网站建设方案策划方案
  • 宠物店网站模板你是网站设计有限公司的项目经理
  • 潍坊网站开发公司2018做网站还赚钱吗
  • 做化妆品网站怎样wordpress映射到外网访问
  • 关于加强门户网站建设爱客crm客户管理系统
  • 网站备案的是域名还是空间电子商务网站建设携程
  • 建设企业网站管理系统目的开发一个网站的费用
  • 网站开发和浏览器兼容问题软文广告案例分析
  • 更新网站的方法自贡网站建设哪家好
  • 沈阳网络建网站个人电子商务网站建设的总体目标
  • asp 大型网站开发优化公司治理结构
  • 做外贸 建网站要注意什么ssr网站怎么做