import com.hc.hc.learnPlan.netty.nettyClientAndServerToStudy.ServerClientTOTalk; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.*; ...
分类：
Web程序 时间：
2020-06-10 21:24:00
阅读次数：
85
6.1.1 Channel 的生命周期 Channel 的正常生命周期如图6-1 所示。当这些状态发生改变时，将会生成对应的事件。 这些事件将会被转发给ChannelPipeline 中的ChannelHandler，其可以随后对它们做出 响应。 由于SimpleChannelInboundHand ...
分类：
其他好文 时间：
2020-06-09 20:24:25
阅读次数：
71
核心部分 NIO( New Input/ Output) , 引入了一种基于通道和缓冲区的 I/O 方式，NIO 是一种同步非阻塞的 IO 模型。同步是指线程不断轮询 IO 事件是否就绪，非阻塞是指线程在等待 IO 的时候，可以同时做其他任务。同步的核心就是 Selector，Selector 代替 ...
分类：
编程语言 时间：
2020-06-08 19:08:32
阅读次数：
53
1.ack和限流 ack也就是消息确认签收，分为自动签收和手动签收。之前的交换机demo中：channel.basicConsume(queueName,true, consumer); 第二个参数就是自动签收，如果我们要手动签收则需要改成false，再去消息处理中手动签收即可 当我们消息队列中已经 ...
分类：
其他好文 时间：
2020-06-08 00:46:55
阅读次数：
42
概念 Flume是一个分布式、可靠、和高可用的海量日志采集、聚合和传输的系统。 模型 a)Source：采集组件，用于跟数据源对接，以获取数据 b)Sink：下沉组件，用于往下一级agent传递数据或者往最终存储系统传递数据 c)Channel：传输通道组件，用于从source将数据传递到sink ...
分类：
Web程序 时间：
2020-06-07 21:04:35
阅读次数：
67
2、Go语言基础之数据类型 Go语言中有丰富的数据类型，除了基本的整型、浮点型、布尔型、字符串外，还有数组、切片、结构体、函数、map、通道（channel）等。 基本数据类型 1.1整型 整型分为以下两个大类： 按长度分为：int8、int16、int32、int64 对应的无符号整型：uint8 ...
分类：
编程语言 时间：
2020-06-07 14:44:13
阅读次数：
68
1.服务端 public class GroupChatServer { private Selector selector; private ServerSocketChannel listenChannel; private static final int PORT = 6677; //初始化 ...
分类：
其他好文 时间：
2020-06-07 10:51:54
阅读次数：
61
1.简单介绍 选择器提供选择执行已经就绪的任务的能力.从底层来看，Selector提供了询问通道是否已经准备好执行每个I/O操作的能力。Selector 允许单线程处理多个Channel。仅用单个线程来处理多个Channels的好处是，只需要更少的线程来处理通道。事实上，可以只用一个线程处理所有的通 ...
分类：
其他好文 时间：
2020-06-07 09:20:18
阅读次数：
80
package main import "fmt" func main() { // make函数 makeSlice() // 创建切片 makeMap() // 创建集合 makeChan() // 创建channel } func makeSlice(){ sl := make([]strin ...
分类：
其他好文 时间：
2020-06-06 20:08:38
阅读次数：
224
package main import ( "time" "fmt" ) func main() { c := make(chan string) go func() { time.Sleep(1 * time.Second) c <- "hello from chan" // 数据发送到chann ...
分类：
其他好文 时间：
2020-06-06 18:45:24
阅读次数：
51
