-
Spring Cloud构建微服务架构：分布式服务跟踪（抽样收集）【Dalston版】
通过 Trace ID和 Span ID已经实现了对分布式系统中的请求跟踪，而这些记录的跟踪信息最终会被分析系统收集起来，并用来实现对分布式系统的监控和分析功能，比如：预警延迟过长的请求链路、查询请求链路的调用明细等。此时，我们在对接分析系统时就会碰到一个问题：分析系统在收集跟踪信息的时候，需要收集多少量的跟踪信息才合适呢？ 理论上来说，我们收集的跟踪信息越多就可以更好的反映出系统的实际运行情况，…- 42
- 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方法的实现逻辑, 这一小…- 1
- 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…- 12
- 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原理系列之（一）消息存储和offset提交机制
kafka之消息存储和offset提交机制 Kafka具有存储功能，默认保存数据时间为7天或者大小1G，也就是说kafka broker上的数据超7天或者1G， 就会被清理掉。这些数据存放在broker服务器上，以log文件的形式存在。 kafka的安装目录下面的/conf/server.propertites文件中中设置： 1### 日志保存时间 (hours|minutes)，默认为7天（16…- 14
- 0
-
RabbitMQ VS Apache Kafka （四）—— 应用场景如何选择？
架构对比 RabbitMQ是一个通用的消息代理，通过包括点对点、请求/响应及发布订阅在内的多种消息通信模式。其采用的是一种智能代理/傻瓜消费的模式，侧重消息的持续投递与处理，并通过代理本身来维护消费者自身状态。RabbitMQ是一个设计成熟的消息代理中间件，支持包括Java, node.js, .NET, Ruby, PHP等在内的多种客户端，并且提供有多种插件来扩展自身功能。 RabbitMQ支…- 7
- 0
-
如何管理Spark Streaming消费Kafka的偏移量（二）
上篇文章，讨论了在spark streaming中管理消费kafka的偏移量的方式，本篇就接着聊聊上次说升级失败的案例。 事情发生一个月前，由于当时我们想提高spark streaming程序的并行处理性能，于是需要增加kafka分区个数，，这里需要说下，在新版本spark streaming和kafka的集成中，按照官网的建议 spark streaming的executors的数量要和kafk…- 21
- 0
-
Kafka vs RocketMQ—— Topic数量对单机性能的影响
引言 上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能，受到了程序猿们的广泛关注，其中大家对这种单纯的发送场景感到并不过瘾，因为没有任何一个网站的业务只有发送消息。本期，我们就来模拟一个真实的场景： 消息的发送和订阅一定是共存的 要支持多个订阅端订阅自己感兴趣的消息 鉴于上一期Kafka和RocketMQ的指标和关注度很高，本期我们将只针对这两个产…- 16
- 0
-
kafka＋zookeeper环境配置（Mac 或者 linux环境）
一.zookeeper下载与安装 1）下载 1adeMacBook-Pro:zookeeper_soft apple$ wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz 2 2）解压 1tar zxvf zookeeper-3.4.6.tar.gz 2 3）配置 1cd zook…- 2
- 0
-
Kafka监控工具KafkaOffsetMonitor配置及使用
一、KafkaOffsetMonitor简述 KafkaOffsetMonitor是Kafka的一款客户端消费监控工具，用来实时监控Kafka服务的Consumer以及它们所在的Partition中的Offset，我们可以浏览当前的消费者组，并且每个Topic的所有Partition的消费情况都可以一目了然。 二、KafkaOffsetMonitor下载 KafkaOffsetMonitor托管…- 41
- 0
-
C# 操作rabbitmq（一）
更多资料参考 http://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html 一、 简单的Helloworld 1 #region pulisher 2 3{ 4 var factory = new ConnectionFactory() { HostName = "localhost", UserName = "…- 9
- 0
-
.Net下RabbitMQ的使用(2) — 发送接收消息
在安装和配置完成RabbitMQ之后，我们就可以尝试做一个最简单的例子：发送和接收消息。 我们先来看客户端也就是发送者的代码： 1public class RabbitClient 2 3{ 4 5 //定义连接工厂 6 7 ConnectionFactory factory = new ConnectionFactory(); 8 9 10 11 public RabbitClient…- 15
- 0
-
RabbitMQ从入门到精通
文章目录 Linux 部署运维 1.安装erlang 2.安装socat 3.安装rabbit MQ 4.查看rabbitmq状态 5.rabbitmq启动 6.rabbitmq的管理界面 7.rabbitmq停止 8.rabbitmq关闭 9.rabbitmq重启 10.配置文件位于/etc/rabbitmq 11.用户管理 12.集群 Client Demo-HelloWorld （JAVA）…- 16
- 0
-
nagios分布式监控配置
一、在分布式机器上安装和nagios主监控机一样配置好，在界面上呈现出相关监控信息后 二、开始安装NSCA模块 下载地址 http://nchc.dl.sourceforge.net/sourceforge/nagios/nsca-2.7.2.tar.gz 安装步骤 ./configure && make all 这样就安装完毕了，下面是客户端相关配置 cd nsca-2.7.2…- 30
- 0
-
Hadoop分布式文件系统
分布式文件系统，架构于网络之上，引入网络编程的复杂性 HDFS:Haddop Distributed Filesystem HDFS设计 超大文件、流式数据访问：HDFS的构建思路是一次写入、多次读取是最高效的访问模式。、商用硬件 低时间延迟的数据访问：HDFS是为高数据吞吐量应用优化的，可能会以提高时间延迟为代价。、大量的小文件：由于namenode将文件系统的元数据存储在内存中，因此该文件系统…- 11
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×