-
Spring Cloud构建微服务架构：分布式服务跟踪（抽样收集）【Dalston版】
通过 Trace ID和 Span ID已经实现了对分布式系统中的请求跟踪，而这些记录的跟踪信息最终会被分析系统收集起来，并用来实现对分布式系统的监控和分析功能，比如：预警延迟过长的请求链路、查询请求链路的调用明细等。此时，我们在对接分析系统时就会碰到一个问题：分析系统在收集跟踪信息的时候，需要收集多少量的跟踪信息才合适呢？ 理论上来说，我们收集的跟踪信息越多就可以更好的反映出系统的实际运行情况，…- 21
- 0
-
ASP.NET Core微服务之基于Steeltoe使用Zipkin实现分布式追踪
一、关于Spring Cloud Sleuth与Zipkin 在 SpringCloud 之中提供的 Sleuth 技术可以实现微服务的调用跟踪，也就是说它可以自动的形成一个调用连接线，通过这个连接线使得开发者可以轻松的找到所有微服务间关系，同时也可以获取微服务所耗费的时间， 这样就可以进行微服务调用状态的监控以及相应的数据分析。 Zipkin是一个分布式追踪系统，它有助于收集解决微服务架构中…- 1
- 0
-
Netty游戏服务器实战开发(1):Netty 的自带解码器
LineBasedFrameDecoder LineBasedFrameDecoder是回车换行解码器，如果用户发送的消息以回车换行符作为消息结束的标识，则可以直接使用Netty的LineBasedFrameDecoder对消息进行解码，只需要在初始化Netty服务端或者客户端时将LineBasedFrameDecoder正确的添加到ChannelPipeline中即可，不需要自己重新实现一套换行…- 10
- 0
-
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)—->第2节: FastThreadLocal的set方法…
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)---->第2节: FastThreadLocal的set方法 Netty源码分析第八章: 高性能工具类FastThreadLocal和Recycler 第二节: FastThreadLocal的set方法 上一小节我们学习了FastThreadLocal的创建和get方法的实现逻辑, 这一小…- 0
- 0
-
Netty源码分析第4章(pipeline)—->第6节: 传播异常事件
Netty源码分析第四章: pipeline 第6节: 传播异常事件 讲完了inbound事件和outbound事件的传输流程, 这一小节剖析异常事件的传输流程 首先我们看一个最最简单的异常处理的场景: 1@Override 2public void channelRead(ChannelHandlerContext ctx, Object msg) throws Except…- 18
- 0
-
Netty源码分析第1章(Netty启动流程)—->第1节: 服务端初始化
Netty源码分析第一章: Server启动流程 概述: 本章主要讲解server启动的关键步骤, 读者只需要了解server启动的大概逻辑, 知道关键的步骤在哪个类执行即可, 并不需要了解每一步的运作机制, 之后会对每个模块进行深度分析 第一节:服务端初始化 首先看下在我们用户代码中netty的使用最简单的一个demo: 1//创建boss和worker线程(1…- 9
- 0
-
Netty In Action中文版 – 第十章：单元测试代码
Netty In Action中文版 - 第十章：单元测试代码 本章介绍 单元测试 EmbeddedChannel 学会了使用一个或多个ChannelHandler处理接收/发送数据消息，但是如何测试它们呢？Netty提供了2个额外的类使得测试ChannelHandler变得很容易，本章讲解如何测试Netty程序。测试使用JUnit4，如果不会用可以慢慢了解。JUnit4很简单，但是功能很强大。本…- 9
- 0
-
Mina、Netty、Twisted一起学（六）：session
开发过Web应用的同学应该都会使用session。由于HTTP协议本身是无状态的，所以一个客户端多次访问这个web应用的多个页面，服务器无法判断多次访问的客户端是否是同一个客户端。有了session就可以设置一些和客户端相关的属性，用于保持这种连接状态。例如用户登录系统后，设置session标记这个客户端已登录，那么访问别的页面时就不用再次登录了。 不过本文的内容不是Web应用的session，而…- 7
- 0
-
Java NIO框架Netty教程（二） – 白话概念
"Hello World" 的代码固然简单，不过其中的几个重要概念（类）和 Netty的工作原理还是需要简单明确一下，至少知道其是负责什。方便自己以后更灵活的使用和扩展。 声明，笔者一介码农，不会那么多专业的词汇和缩写，只能以最简单苍白的话来形容个人的感受和体会。如果您觉得这太不专业，笔者首先只能抱歉。然后，笔者曾转过《 Netty代码分析》，您可参考。 ChannelEv…- 7
- 0
-
Java NIO框架Netty教程(十四)-Netty中OIO模型(对比NIO)
OneCoder这个周末搬家，并且新家目前还没有网络，本周的翻译的任务尚未完成，下周一起补上，先上一篇OIO和NIO对比的小研究。 Netty中不光支持了Java中NIO模型，同时也提供了对OIO模型的支持。（New IO vs Old IO）。 首先，在Netty中，切换OIO和NIO两种模式是非常方便的，只需要初始化不同的Channel工程即可。 1ServerBootstrap bootst…- 22
- 0
-
一个轻量级分布式RPC框架–NettyRpc
1、背景 最近在搜索Netty和Zookeeper方面的文章时，看到了这篇文章《轻量级分布式 RPC 框架》，作者用Zookeeper、Netty和Spring写了一个轻量级的分布式RPC框架。花了一些时间看了下他的代码，写的干净简单，写的RPC框架可以算是一个简易版的dubbo。这个RPC框架虽小，但是麻雀虽小，五脏俱全，有兴趣的可以学习一下。 本人在这个简易版的RPC上添加了如下特性： * 服…- 16
- 0
-
kafka原理和实践（六）总结升华
目录 总结篇 1.官方介绍 2.特点 3.Kafka的设计 4.Kayka的应用场景 5.总结 正文 系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置…- 8
- 0
-
kafka原理和实践（一）原理：10分钟入门
目录 一、kafka拓扑图 二、名词解释 三、生产模型 四、消费模型 正文 系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置详解 kafka原理和实践…- 3
- 0
-
如何管理Spark Streaming消费Kafka的偏移量（一）
本篇我们先从理论的角度聊聊在Spark Streaming集成Kafka时的offset状态如何管理。 spark streaming 版本 2.1 kafka 版本0.9.0.0 在这之前，先重述下spark streaming里面管理偏移量的策略，默认的spark streaming它自带管理的offset的方式是通过checkpoint来记录每个批次的状态持久化到HDFS中，如果机器发生故障…- 18
- 0
-
rocketMq和kafka的架构区别
概述 其实一直想写一篇rocketMq和kafka在架构设计上的差别，但是一直有个问题没搞明白所以迟迟没动手，今天无意中听人点播了一下似乎明白了这个问题，所以就有了这篇对比。 这篇博文主要讲清楚kafka和rocketMq的两个不同点，1、rocketMq的namesvr和kafka的zookeeper对比；2、kafka为什么比rocketMq有更大的吞吐量。如果能够讲清楚上面两…- 10
- 0
-
Docker下RabbitMQ四部曲之三：细说java开发
本文是《Docker下RabbitMQ四部曲》系列的第三篇，实战两个基于SpringBoot的工程，分别用来生产和消费RabbitMQ消息； 本文内容简述 今天的实战由以下几部分组成： 开发SpringBoot工程rabbitmqproducer，用来生产消息； 分析docker-compose.yml中对rabbitmqproducer镜像的使用； 开发SpringBoot工程rabbitmqc…- 13
- 0
-
使用Zabbix监控RabbitMQ
一 应用场景描述 线上业务使用RabbitMQ作为消息队列中间件，那么作为运维人员对RabbitMQ的监控就很重要，本文就针对如何从头到尾使用Zabbix来监控RabbitMQ进行说明。 二 RabbitMQ监控要点 RabbitMQ官方提供两种方法来管理和监控RabbitMQ。 1.使用rabbitmqctl管理和监控 Usage: rabbitmqctl [-n <node>] […- 81
- 0
-
AMQP-RabbitMQ/1/概念/一对一简单模型
# JMS,AMQP,MQTT的区别与联系 JMS Java消息传递服务（Java Messaging Service ） AMQP 高级消息队列协议（Advanced Message Queueing Protocol ） MQTT 消息队列遥测传输（Message Queueing Telemetry Transport ） 简单理解： *JMS是专门为Java设计的一套消息服务API，像Ac…- 15
- 0
-
RabbitMQ消息队列（四）：分发到多Consumer（Publish/Subscribe）
上篇文章中，我们把每个Message都是deliver到某个Consumer。在这篇文章中，我们将会将同一个Message deliver到多个Consumer中。这个模式也被成为 "publish / subscribe"。 这篇文章中，我们将创建一个日志系统，它包含两个部分：第一个部分是发出log（Producer），第二个部分接收到并打印（Consumer）。 我们将构建…- 6
- 0
-
RabbitMQ安装
部署安装RabbitMQ前，先了解下基本概念：（RabbitMQ+Python入门经典] 兔子和兔子窝） RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连…- 22
- 0
-
rabbitMQ基础
目录 jar包 消息类型 简单模型Hello Word 工作队列模式Work Queue Round-robin （轮询分发） Fair dispatch （公平分发） 订阅 模式 Publish/Subscribe 路由模式 通配符模式Topic RabbitMQ 之消息确认机制（事务+Confirm ） 概述 事务机制 Confirm 模式 jar包 1<dependency&g…- 2
- 0
-
分布式与集群的区别是什么？
分布式：一个业务分拆多个子业务，部署在不同的服务器上 集群：同一个业务，部署在多个服务器上 单机结构 我想大家最最最熟悉的就是单机结构，一个系统业务量很小的时候所有的代码都放在一个项目中就好了，然后这个项目部署在一台服务器上就好了。整个项目所有的服务都由这台服务器提供。这就是单机结构。 那么，单机结构有啥缺点呢？我想缺点是显而易见的，单机的处理能力毕竟是有限的，当你的业务增长到一定程度的时候，单机…- 7
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×