-
Spring Cloud构建微服务架构:分布式服务跟踪(收集原理)【Dalston版】
在本节内容之前,我们已经对如何引入Sleuth跟踪信息和搭建Zipkin服务端分析跟踪延迟的过程做了详细的介绍,相信大家对于Sleuth和Zipkin已经有了一定的感性认识。接下来,我们介绍一下关于Zipkin收集跟踪信息的过程细节,以帮助我们更好地理解Sleuth生产跟踪信息以及输出跟踪信息的整体过程和工作原理。 数据模型 我们先来看看Zipkin中关于跟踪信息的一些基础概念。由于Zipkin的…- 5
- 0
-
Openstack+Kubernetes+Docker微服务实践之路–Kubernetes
经过几番折腾终于搞定Kubernetes了,我们要在Openstack上部署Kubernetes集群,使用最新工具Kubeadm来安装,由于不能直接访问Kubernetes的源,我们需要一台可以穿墙的机器,可以是个人电脑,另外需要一台基于Docker快照的云主机,将下载后的所有资源放到这台机器中生成新的Kubernetes快照,用来做为以后Kubernetes集群的系统基础。 下载Kubernet…- 19
- 0
-
Netty游戏服务器实战开发(4):自定义消息池化处理
通过上篇《Netty游戏服务器实战开发(3):自定义消息》我们都知道,客户端发送过来的消息我们服务器通过自定义编解码实现解析每条消息,并且做对应的处理,但是当批量消息到达的时候我们不能做出及时处理,需要将消息放到队列中,然后在进行处理,提高系统的性能。但是上篇介绍的重点是消息的编解码,接下来我们介绍消息的处理,并且利用线程池化技术实现消息队列处理。 首先我们来复习一下java提供的几种队列模型。 …- 8
- 0
-
Netty源码分析第4章(pipeline)—->第7节: 前章节内容回顾
Netty源码分析第4章(pipeline)---->第7节: 前章节内容回顾 Netty源码分析第四章: pipeline 第七节: 前章节内容回顾 我们在第一章和第三章中, 遗留了很多有关事件传输的相关逻辑, 这里带大家一一回顾 首先看两个问题: 1.在客户端接入的时候, NioMessageUnsafe的read方法中pipeline.fireChannelRead(rea…- 5
- 0
-
Netty In Action中文版 – 第十五章:选择正确的线程模型
Netty In Action中文版 - 第十五章:选择正确的线程模型 本章介绍 线程模型(thread-model) 事件循环(EventLoop) 并发(Concurrency) 任务执行(task execution) 任务调度(task scheduling) 线程模型定义了应用程序或框架如何执行你的代码,选择应用程序/框架的正确的线程模型是很重要的。Netty提供了一个简单强大的线程模型…- 3
- 0
-
[编织消息框架][netty源码分析]3 EventLoop 实现类SingleThreadEventLoop职责与实现
eventLoop是基于事件系统机制,主要技术由线程池同队列组成,是由生产/消费者模型设计,那么先搞清楚谁是生产者,消费者内容 SingleThreadEventLoop 实现 1public abstract class SingleThreadEventLoop extends SingleThreadEventExecutor implements EventLoop { 2 private…- 0
- 0
-
100万并发连接服务器笔记之Java Netty处理1M连接会怎么样
五 100万并发连接服务器笔记之Java Netty处理1M连接会怎么样 2014年05月21日 14:13:56 mergerly 阅读数:20545 前言 每一种该语言在某些极限情况下的表现一般都不太一样,那么我常用的Java语言,在达到100万个并发连接情况下,会怎么样呢,有些好奇,更有些期盼。 这次使用经常使用的顺手的netty NIO框架(netty-3.6.5.Final),封装的很好…- 1
- 0
-
Java NIO框架Netty教程(五)-Netty中OIO模型(对比NIO)
一篇OIO和NIO对比的小研究。Netty中不光支持了Java中NIO模型,同时也提供了对OIO模型的支持。(New IO vs Old IO)。 首先,在Netty中,切换OIO和NIO两种模式是非常方便的,只需要初始化不同的Channel工程即可。 1ServerBootstrap bootstrap =new ServerBootstrap( 2 newOioServerSocketChan…- 1
- 0
-
Netty实现Http服务器
Netty实现Http服务器 Netty是一个异步事件驱动的网络应用程序框架用于快速开发和可维护的高性能协议服务器和客户端。Netty经过精心设计,具有丰富的协议,如FTP,SMTP,HTTP以及各种二进制和基于文本的传统协议。 Java程序员在开发web应用的时候,…- 2
- 0
-
基于Dubbo框架构建分布式服务
Dubbo是Alibaba开源的分布式服务框架,我们可以非常容易地通过Dubbo来构建分布式服务,并根据自己实际业务应用场景来选择合适的集群容错模式,这个对于很多应用都是迫切希望的,只需要通过简单的配置就能够实现分布式服务调用,也就是说服务提供方(Provider)发布的服务可以天然就是集群服务,比如,在实时性要求很高的应用场景下,可能希望来自消费方(Consumer)的调用响应时间最短,只需要选…- 6
- 0
-
kafka原理系列之(一)消息存储和offset提交机制
kafka之消息存储和offset提交机制 Kafka具有存储功能,默认保存数据时间为7天或者大小1G,也就是说kafka broker上的数据超7天或者1G, 就会被清理掉。这些数据存放在broker服务器上,以log文件的形式存在。 kafka的安装目录下面的/conf/server.propertites文件中中设置: 1### 日志保存时间 (hours|minutes),默认为7天(16…- 13
- 0
-
RabbitMQ VS Apache Kafka (四)—— 应用场景如何选择?
架构对比 RabbitMQ是一个通用的消息代理,通过包括点对点、请求/响应及发布订阅在内的多种消息通信模式。其采用的是一种智能代理/傻瓜消费的模式,侧重消息的持续投递与处理,并通过代理本身来维护消费者自身状态。RabbitMQ是一个设计成熟的消息代理中间件,支持包括Java, node.js, .NET, Ruby, PHP等在内的多种客户端,并且提供有多种插件来扩展自身功能。 RabbitMQ支…- 4
- 0
-
如何管理Spark Streaming消费Kafka的偏移量(二)
上篇文章,讨论了在spark streaming中管理消费kafka的偏移量的方式,本篇就接着聊聊上次说升级失败的案例。 事情发生一个月前,由于当时我们想提高spark streaming程序的并行处理性能,于是需要增加kafka分区个数,,这里需要说下,在新版本spark streaming和kafka的集成中,按照官网的建议 spark streaming的executors的数量要和kafk…- 14
- 0
-
Kafka vs RocketMQ—— Topic数量对单机性能的影响
引言 上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能,受到了程序猿们的广泛关注,其中大家对这种单纯的发送场景感到并不过瘾,因为没有任何一个网站的业务只有发送消息。本期,我们就来模拟一个真实的场景: 消息的发送和订阅一定是共存的 要支持多个订阅端订阅自己感兴趣的消息 鉴于上一期Kafka和RocketMQ的指标和关注度很高,本期我们将只针对这两个产…- 5
- 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托管…- 31
- 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 = "…- 6
- 0
-
.Net下RabbitMQ的使用(2) — 发送接收消息
在安装和配置完成RabbitMQ之后,我们就可以尝试做一个最简单的例子:发送和接收消息。 我们先来看客户端也就是发送者的代码: 1public class RabbitClient 2 3{ 4 5 //定义连接工厂 6 7 ConnectionFactory factory = new ConnectionFactory(); 8 9 10 11 public RabbitClient…- 5
- 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)…- 6
- 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…- 12
- 0
-
Hadoop分布式文件系统
分布式文件系统,架构于网络之上,引入网络编程的复杂性 HDFS:Haddop Distributed Filesystem HDFS设计 超大文件、流式数据访问:HDFS的构建思路是一次写入、多次读取是最高效的访问模式。、商用硬件 低时间延迟的数据访问:HDFS是为高数据吞吐量应用优化的,可能会以提高时间延迟为代价。、大量的小文件:由于namenode将文件系统的元数据存储在内存中,因此该文件系统…- 8
- 0
幸运之星正在降临...
点击领取今天的签到奖励!
恭喜!您今天获得了{{mission.data.mission.credit}}积分
我的优惠劵
-
¥优惠劵使用时效:无法使用使用时效:
之前
使用时效:永久有效优惠劵ID:×
没有优惠劵可用!