-
ASP.NET Core微服务之基于Steeltoe使用Hystrix熔断保护与监控
Tip: 此篇已加入.NET Core微服务基础系列文章索引 => Steeltoe目录快速导航： 基于Steeltoe使用Spring Cloud Eureka 基于Steeltoe使用Spring Cloud Zuul 基于Steeltoe使用Spring Cloud Hystrix 一、关于Spring Cloud Hystrix 在微服务架构中，我们将系统拆分为很多个服务，各个服务…- 0
- 0
-
Netty游戏服务器实战开发(12)：线程任务组件开发
导读： 线程在java里面很多，本文不会介绍线程使用，只会介绍大型项目线程组件的开发模式。 一个大型项目中少不了对多线程的使用，在使用多线程的时候，可以使用Java 的API提供的Thread或者Runnable。随着API的丰富和发展，对程序员来说使用和管理线程也变得越来越方便了。例如我们利用线程池来管理线程，很常见的做法就是： 1 public void testThread() { 2 Ex…- 46
- 0
-
Netty源码分析第7章(编码器和写数据)—->第3节: 写buffer队列
Netty源码分析第7章(编码器和写数据)---->第3节: 写buffer队列 Netty源码分析七章: 编码器和写数据 第三节: 写buffer队列 之前的小节我们介绍过, writeAndFlush方法其实最终会调用write和flush方法 write方法最终会传递到head节点, 调用HeadContext的write方法: 1public void write(C…- 14
- 0
-
Netty源码分析第4章(pipeline)—->第4节: 传播inbound事件
Netty源码分析第四章: pipeline 第四节: 传播inbound事件 有关于inbound事件, 在概述中做过简单的介绍, 就是以自己为基准, 流向自己的事件, 比如最常见的channelRead事件, 就是对方发来数据流的所触发的事件, 己方要对这些数据进行处理, 这一小节, 以激活channelRead为例讲解有关inbound事件的处理流程 在业务代码中, 我们…- 24
- 0
-
Netty源码分析第2章(NioEventLoop)—->第2节: NioEventLoopGroup之NioEventLoop的创建
Netty源码分析第二章: NioEventLoop ** ** 第二节: NioEventLoopGroup之NioEventLoop的创建 回到上一小节的 MultithreadEventExecutorGroup 类的构造方法 : 1protected MultithreadEventExecutorGroup(int nThreads, Executor executor, 2 E…- 1
- 0
-
[编织消息框架][netty源码分析]1分析切入点
在分析源码之前有几个疑问 1.BOSS线程如何转交给handle(业务)线程 2.职业链在那个阶段执行 3.socket accept 后转给上层对象是谁 4.netty控流算法 另外要了解netty的对象设计职责 1.channel 2.pipeline 3.promise 4.eventLoop 5.handle 6.byteBuf 7.unsafe 分析netty用的是4.1.8.Fin…- 8
- 0
-
Mina、Netty、Twisted一起学（四）：定制自己的协议
在前面的博文中，介绍一些消息分割的方案，以及MINA、Netty、Twisted针对这些方案提供的相关API。例如MINA的TextLineCodecFactory、PrefixedStringCodecFactory，Netty的LineBasedFrameDecoder、LengthFieldBasedFrameDecoder，Twisted的LineOnlyReceiver、Int32Str…- 11
- 0
-
Java NIO框架Netty教程（四） – ServerBootStrap启动流程源码分析
有一段事件没有更新文章了，各种原因都有吧。搬家的琐事，搬家后的安逸呵呵。不过，OneCoder明白，绝不能放松。对于Netty的学习，也该稍微深入一点了。 所以，这次 OneCoder花了几天时间，仔细梳理了一下Netty的源码，总结了一下ServerBootStrap的启动和任务处理流程，基本涵盖了Netty的关键架构。 OneCoder总结了一张流程图： 该图是 OneCoder通…- 31
- 0
-
Java NIO框架Netty教程(三) 字符串消息收发（转）
了解了Netty的基本概念(http://www.it165.net/pro/html/201207/3173.html)，开发起来应该会顺手很多。 在“Hello World(http://www.it165.net/pro/html/201207/3142.html)”代码中，我们只是在完成绑定的时候，在各自的本地打印了简单的信息，并没有客户端和服务端的消息传递。这个肯定是最基本的功能。在上代…- 37
- 0
-
go-kit实践之3：go-kit 微服务的限流实现
介绍 go-kit提供了限流模块，该模块采用令牌桶算法实现，其实是封装了一下golang自带的golang.org/x/time/rate包来实现的。 令牌桶 令牌桶这种控制机制基于令牌桶中是否存在令牌来指示什么时候可以发送流量。令牌桶中的每一个令牌都代表一个字节。如果令牌桶中存在令牌，则允许发送流量；而如果令牌桶中不存在令牌，则不允许发送流量。因此，如果突发门限被合理地配置并且令牌桶中有足够的令…- 8
- 0
-
基于Dubbo框架构建分布式服务
转自：http://shiyanjun.cn/archives/1075.html 很好的文章 Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，…- 2
- 0
-
Kafka实战(二) – 摸清 Kafka 的"黑话"
Kafka属分布式消息引擎系统,提供一套完备的消息发布与订阅解决方案。 在Kafka中，发布订阅的对象是主题（Topic），可为每个业务、每个应用甚至是每类数据都创建专属的主题。 1 Producer & Consumer 向主题发布消息的客户端应用称为生产者（Producer），生产者程序通常持续不断地向一个或多个主题发送消息，而订阅这些主题消息的客户端应用程序就被称为消费者（Consu…- 6
- 0
-
STM32学习笔记之二：三种BOOT启动方式的使用
不同设计场景中的三种BOOT启动方式选择 最近需要用到STM32系列的芯片来做一个项目，之前接触的都是51和430系列的单片机，初次接触ST的，发现ST与之前的所接触的单片机的不同之一在于：ST芯片在下载方式的选择以及程序的启动方式是需要设计开发人员自己选择的，而51和430系列的单片机都是系统默认选择好的，这个是我认为的和之前所接触的单片机最大的不同点之一了（个人观点，可能有偏差）。好了，废话不…- 61
- 0
-
flume-ng+Kafka+Storm+HDFS 实时系统搭建
以下是我的flume配置文件,有一些重要的配置项我都加了注释。 ############################################ # producer config ########################################### #agent section producer.sources = s producer.channels = c c1…- 9
- 0
-
SparkStreaming:SparkStreaming简介及架构,WordCount案例,Dstream入门,文件及自定义数据源,Kafka数据源（重点）,DStream创建转换输出,状态转化操作
文章目录 第1章 Spark Streaming概述 1.1 Spark Streaming是什么 1.2 Spark Streaming特点 1.3 SparkStreaming架构 第2章 Dstream入门 2.1 WordCount案例实操 2.2 WordCount解析 第3章 Dstream创建 3.1文件数据源 3.1.1 用法及说明 3.1.2 案例实操 3.2 RDD队列（了解）…- 3
- 0
-
Java使用RabbitMQ（七）–Routing
Routing 路由选择 前面的文章 介绍了，怎么广播消息到多个接收者，这一篇将怎么订阅消息的子集。 比如指定一个消费者只把 错误日志写入磁盘，另一个消费者仍然能够将所有的日志消息打印到屏幕上。 Binding 一个Binding描述的是交换机和队列之间的关系，比如描述 某个队列对这个交换机中的哪些消息感兴趣。 1channel.queueBind(queueName, EXCHANGE_NAME…- 4
- 0
-
Kafka 常用命令
Kafka 的主要工具类如下（包路径为： kafka.tool.*）： 大家更加版本，可自行查看： https://github.com/apache/kafka/tree/trunk/core/src/main/scala/kafka/tools 获取当前消费进度 bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list …- 9
- 0
-
AMQP-RabbitMQ/5/主题模式
5. 主题模式 Topics 根据主题接收消息 routing_key - 它必须是由英文点.分隔的单词列表 *可以替代一个单词。 ＃可以替换零个或多个单词。 图示 个人理解 与路由模式基本相同，不同的点只是路由模式需要Queue订阅的路由键与消息的路由键完全匹配，Exchange才会将消息发送给Queue。 而主题模式(Exchange类型为topic)，消费者在将Exchange与Queue绑…- 1
- 0
-
基于Python语言使用RabbitMQ消息队列（一）
介绍 RabbitMQ 是一个消息中间人（broker）: 它接收并且发送消息. 你可以把它想象成一个邮局: 当你把想要寄出的信放到邮筒里时, 你可以确定邮递员会把信件送到收信人那里. 在这个比喻中, RabbitMQ 就是一个邮筒, 同时也是邮局和邮递员 . 和邮局的主要不同点在于RabbitMQ不处理纸质信件, 而是 接收（accepts）, 存储（stores） 和转发（forwards）二…- 6
- 0
-
RabbitMQ-整合Spring AMQP实战
文章目录 RabbitAdmin RabbitTemplate SimpleMessageListenerContainer(消息监听容器；可以运行中, 动态修改) MessageListenerAdapter(消息监听适配器) MessageConverter(消息转换器) 1. RabbitAdmin 概述 可以把RabbitAdmin作为Spring的一个Bean，然后细粒度的操作Rabbi…- 12
- 0
-
RabbitMQ基本原理
MQ是一种消息队列 项目中需要对接Java系统,这里做一下总结。 RabbitMQ 消息走向流程 Producer 消息生产者，Consumer消息消费者，Exchagne交换机，Queue队列。 Producer负责将数据发送到Exchange中，Consumer负责从Queue中取消息。 Exchange绑定多个Queue 一个交换机可以和多个Qeueu绑定 有三类交换机，分别是Diredct…- 20
- 0
-
RabbitMQ三种分布式策略总结
规约： exchange 交换机 queue 队列 broker 中间服务器/服务器 cluster 集群 node 节点 route 路由 RabbitMQ可以通过三种方法部署分布式系统：集群、联盟（federation）和shovel。 集群通过连接多个机器组成单个逻辑中间服务器。机器之间通信要借助于Erlang的消息传输，要求集群中所有节点…- 15
- 0
-
docker安装RabbitMQ
rabbitMQ是一款开源的高性能消息中间件，最近项目要使用，于是使用docker搭建，快速方便。 一、获取镜像 使用docker search rabbitMq命令获取镜像列表，结果如下 2.使用docker pull docker.io/rabbitmq:3.8-management 拉取镜像，我们选择了STARS数最多的官方镜像，此处需要注意，默认rabbitmq镜像是不带web端管理插件的…- 17
- 0
-
19. Dubbo原理解析-通信层之暴露服务
Dubbo的整个远程通信层由exchange,transport, serialize exchange，信息交换层，封装请求响应模式，同步转异步，以Request, Response为中心，扩展接口为Exchanger, ExchangeChannel, HeaderExchangeHandler,ExchangeClient, ExchangeServer transport，网络传输…- 26
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×