【Netty】01 - NIO
一. NIO 基础 non-blocking io 非阻塞 IO 1.1 Channel & Buffer channel 有一点类似于 stream，它就是读写数据的双向通道，可以从 channel 将数据读入 buffer，也 ......![]()
学习完nio的一个小笔记吧
这是一个nio网络通信服务端的demo，主要就学习了selector的一些用法，以及它里面的事件类型 selector是对nio的一个优化，它能保证既能高效处理线程中的事件，又能保 ......Spark Streaming状态管理函数updateStateByKey和mapWithState
Spark Streaming状态管理函数updateStateByKey和mapWithState 一、状态管理函数 二、mapWithState 2.1关于mapWithState 2.2mapWithState示例Scala： 2.3mapWithStat ......![]()
java select单线程 服务器
package com.Select; /** *select单线程 服务器 **/ import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import ja ......【源码解析】阿里在线诊断工具greys源码
撸起袖子加油干！开门见山！ 一、源码下载 下载代码： git clone https://github.com/oldmanpushcart/greys-anatomy.git 二、源码分析 2.1 目录介绍 用Idea打开greys ......![]()
Zookeeper+Kafka+Spark streaming单机整合开发
环境准备： ubuntu 开发环境： jdk 1.8 scala：2.11.0 spark 2.0 zookeeper 3.4.6 kafka 2.12-0.10.2.0 开始整合： 1 zookeeper的安装，这里我使用的zookeeper版本为 ......reactor模式：单线程的reactor模式
reactor模式称之为响应器模式，常用于nio的网络通信框架，其服务架构图如下 不同于传统IO的串行调度方式，NIO把整个服务请求分为五个阶段 read：接收到请求，读取数 ......![]()
spark streaming 消费 kafka入门采坑解决过程
kafka 服务相关的命令 开启kafka的服务器bin/kafka-server-start.sh -daemon config/server.properties & 创建topicbin/kafka-topics.sh --create --zookeepe ......reactor模式：主从式reactor
前面两篇文章提到 reactor模式：单线程的reactor模式 reactor模式：多线程的reactor模式 NIO的server模式只有5个阶段，但是，NIO的selectionkey里确实有个accept事件 ......![]()
↓ 按住下拉
V2AS = Way To Ask
V2AS 一个技术分享与创造的静土
手机扫一扫
移动阅读更方便
近15日热搜文章