240 发简信
  • 聊一聊 tcp 重传次数

    [TOC]在RTO的计算方法中,介绍了RFC6298对于RTO的计算和RTO timer的管理算法。但有一个重要的问题RFC没有提到,那就是如果...

    0.1 31 0 1
  • 120
    sarama 客户端 producer 源码分析

    具体流程如下图: Sarama有两种类型的生产者,同步生产者和异步生产者。 To produce messages, use either th...

  • golang 单向 chan类型

    [TOC] golang 函数返回chan类型 在阅读kafka的golang 客户端代码sarama-cluster时,遇到了如下一段代码: ...

    1.4 75 0 1
  • 120
    go context

    [TOC]相信大家在日常工作开发中一定会看到这样的代码: context被当作第一个参数(官方建议),并且不断透传下去,基本一个项目代码中到处都...

  • Go Select 详解

    [TOC] 导读 select是一种go可以处理多个通道之间的机制,看起来和switch语句很相似,但是select其实和IO机制中的selec...

  • go 进阶语法

    [TOC] 1 结构体 在Java中,我们已经体会过了面向对象的方便之处。我们只需要将现实中的模型抽象出来,就成为了一个类,类里面定义了描述这个...

  • go 并发

    [TOC]并发程序指同时进行多个任务的程序,随着硬件的发展,并发程序变得越来越重要。Web服务器会一次处理成千上万的请求,这也是并发的必要性之一...

  • 120
    Topic 与 Broker 之间的秘密

    接下来就一起看看在 Pular 里,topic 和 broker 之间到底如何相处的吧。 Topic Discovery Pulsar 作为多租...

  • 120
    pulsar 以Segment为中心的架构

    Pulsar的分层架构 Apache Pulsar和其他消息系统最根本的不同是采用分层架构。 Apache Pulsar集群由两层组成:无状态服...