-
Netty源码分析第2章(NioEventLoop)—->第8节: 执行任务队列
** ** Netty源码分析第二章: NioEventLoop ** ** 第八节: 执行任务队列 继续回到NioEventLoop的run()方法: 1protected void run() { 2 for (;;) { 3 try { 4 switch (selectStrategy.calculateStrategy(selectNowSupplier, hasTasks())) { 5…- 4
- 0
-
Netty In Action中文版 – 第十二章：SPDY
Netty In Action中文版 - 第十二章：SPDY 本章我将不会直接翻译Netty In Action书中的原文，感觉原书中本章讲的很多废话，我翻译起来也吃力。所以，本章内容我会根据其他资料和个人理解来讲述。 12.1 SPDY概念及背景 SPDY是Google开发的基于传输控制协议（TCP）的应用层协议，开发组正在推动SPDY成为正式标准（现为互联网草案）.SPDY协议…- 5
- 0
-
Netty In Action中文版 – 第三章：Netty核心概念
Netty In Action中文版 - 第三章：Netty核心概念 在这一章我们将讨论Netty的10个核心类，清楚了解他们的结构对使用Netty很有用。可能有一些不会再工作中用到，但是也有一些很常用也很核心，你会遇到。 Bootstrap or ServerBootstrap EventLoop EventLoopGroup ChannelPipeline Channel Future or …- 0
- 0
-
Mina、Netty、Twisted一起学（一）：实现简单的TCP服务器
MINA、Netty、Twisted为什么放在一起学习？首先，不妨先分别看一下它们官方网站对其的介绍： MINA： Apache MINA is a network application framework which helps users develop high performance and high scalability network applications easily. It…- 4
- 0
-
Java NIO框架Netty教程(七)-再谈收发信息次数问题
在《Java NIO框架Netty教程（五）- 消息收发次数不匹配的问题》里我们试图分析一个消息收发次数不匹配的问题。当时笔者还是心存疑惑的。所以决定先学习一下Java NIO的Selector机制。 经过简单的了解，笔者大胆的猜测和“武断”一下该问题的原因。 首先，Selector机制让我们注册一个感兴趣的时间，然后只要有该时间发生，就会传递给接收端。我们写了三次，接收端一定会出发三次的。 然后…- 16
- 0
-
netty实现websocket
1.搭建springboot web 项目，参考 https://blog.csdn.net/u013184307/article/details/98057621 2.导入包 1<dependency> 2 <groupId>io.netty</groupId> 3 <artifactId>netty-all</artifactId> …- 9
- 0
-
SpringBoot整合Netty
文章目录 1.依赖 2.配置文件 3.项目结构 4.启动类 5.netty启动类 6.netty配置类 1.依赖 1<?xml version="1.0" encoding="UTF-8"?> 2<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&q…- 38
- 0
-
基于Dubbo框架构建分布式服务
转自：http://shiyanjun.cn/archives/1075.html 很好的文章 Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，…- 4
- 0
-
kafka原理和实践（二）spring-kafka简单实践
系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置详解 kafka原理和实践（六）总结升华 =========正文分割线==============…- 5
- 0
-
RabbitMQ VS Apache Kafka （二）—— Kafka简介
接上一章【RabbitMQ VS Apache Kafka （一）】，本章我们讨论Kafka。 Kafka Kafka is a distributed, replicated commit log. Kafka本身没有队列的概念，作为一个消息中间件，乍听起来，这略显奇怪，这可能与我们长期以来的形成的一个固化思维有关——但凡消息系统，肯定离不开消息队列。让我们重新回头来看，如何理解distribu…- 2
- 0
-
Kafka的通讯协议
Kafka的通讯协议 Kafka的Producer、Broker和Consumer之间采用的是一套自行设计的基于TCP层的协议。Kafka的这套协议完全是为了Kafka自身的业务需求而定制的，而非要实现一套类似于Protocol Buffer的通用协议。本文将介绍这套协议的相关内容。 基本数据类型 定长数据类型：int8,int16,int32和int64，对应到Java中就是byte, shor…- 50
- 0
-
在Windows安装运行Kafka
一、安装JAVA JDK 1、下载安装包 http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html 注意：根据32/64位操作系统下载对应的安装包 2、添加系统变量：JAVA_HOME=C:\Program Files (x86)\Java\jdk1.8.0_144 二、安装ZooKeep…- 6
- 0
-
Flume整合Kafka
Flume 整合 Kafka 一、背景 先说一下，为什么要使用 Flume + Kafka？ 以实时流处理项目为例，由于采集的数据量可能存在峰值和峰谷，假设是一个电商项目，那么峰值通常出现在秒杀时，这时如果直接将 Flume 聚合后的数据输入到 Storm 等分布式计算框架中，可能就会超过集群的处理能力，这时采用 Kafka 就可以起到削峰的作用。Kafka 天生为大数据场景而设计，具有高吞吐的特…- 10
- 0
-
C# 操作rabbitmq（五）
此篇介绍rabbitmq的RPC 一、 虽然我们可以使用work queue给worker发送消息，但是如果我们希望在远程服务器上运行一个方法并且想要得到结果呢？rabbitmq的RPC功能可以实现。 二、 Callback queue，回调队列，在rabbitmq上构建RPC是很容易的，客户端发送请求消息，服务端响应回复消息，为了接收响应消息，我们需要在发送请求的时候附加一个callback 队…- 33
- 0
-
.Net下RabbitMQ的使用(5) — 路由机制
理清路由机制是了解RabbitMQ来龙去脉的关键。在前面的例子中我们常常遇见这三个概念：exchange，routingKey 和 queue。真正地消息传输流程是消息先到exchange，然后exchange根据对应的routingKey放入queue，如果routingKey不匹配则丢弃。网上网友的一张图很好的展示了这个流程： 0.9 版本的AMQP协议的exchange有如下4中类型…- 6
- 0
-
RabbitMQ消息队列（七）：适用于云计算集群的远程调用(RPC)
在云计算环境中，很多时候需要用它其他机器的计算资源，我们有可能会在接收到Message进行处理时，会把一部分计算任务分配到其他节点来完成。那么，RabbitMQ如何使用RPC呢？在本篇文章中，我们将会通过其它节点求来斐波纳契完成示例。 1. 客户端接口 Client interface 为了展示一个RPC服务是如何使用的，我们将创建一段很简单的客户端class。 它将会向外提供名字为call的函数…- 18
- 0
-
rabbitmq工作队列
rabbitmq 工作队列 一、rabbitmq 工作队列简介 在上一篇文章中，讲述了rabbitmq 消息队列的基本使用，属于一个队列值对应一个消费者，在处理耗时应用时，一个工人处理过慢的话，消息会整个堆积在队列里面，继而可能造成不可预测的影响！ 工作队列又称之为任务队列，他主要就是为了解决在执行密集型耗时任务时，消息可以根据消费者的负荷进行合理的分配，从而不会形成一个消费者忙死，另外一个消费者…- 4
- 0
-
大型网站架构之分布式消息队列
一、消息队列概述 消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。 目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。 二、消息队列应用场景 以下介绍消息队列在实际应用中常用的使用场景。异步处理，应用解耦…- 4
- 0
-
9. Dubbo原理解析-代理之服务引用
服务引用是服务的消费方向注册中心订阅服务提供方提供的服务地址后向服务提供方引用服务的过程。 服务的应用方在spring的配置实例如下： < dubbo:reference id="demoService" * interface="com.alibaba.dubbo.demo. DemoService"* /> 如上配置spring在容器启动的时…- 2
- 0
-
4. Dubbo原理解析-代理之接口定义
代理模式这里不再逻辑介绍，dubbo中有使用这种模式，如： dubbo服务的消费端获取的就是对远程服务的一个代理。Dubbo由代理工厂ProxyFactory对象创建代理对象 一：ProxyFactory的接口定义 @SPI( "javassist") public interface ProxyFactory { @Adaptive({Constants.PROXY_K…- 11
- 0
-
初识Dubbo 系列之9-Dubbo 负载均衡
负载均衡 (+) (#) 在集群负载均衡时，Dubbo提供了多种均衡策略，缺省为random随机调用。 1 可以自行扩展负载均衡策略，参见：负载均衡扩展 Random LoadBalance 随机，按权重设置随机概率。 在一个截面上碰撞的概率高，但调用量越大分布越均匀，而且按概率使用权重后也比较均匀，有利于动态调整提供者权重。 RoundRobin LoadBalance 轮循，按公约后的权重设置…- 1
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×