锐客网

  1. 首页 > 睿知 > it技术 > >

go语言缓冲通道 golang通道( 三 )

IT技术代码


所以他们的区别就在于 bytes.Buffer 是重新申请了一块空间，存放生成的string变量， 而strings.Builder直接将底层的[]byte转换成了string类型返回了回来，去掉了申请空间的操作 。
go语言无缓冲的channel无缓冲的通道（unbuffered channel）是指在接收前没有能力保存任何值的通道 。
这种类型的通道要求发送goroutine和接收goroutine同时准备好 ， 才能完成发送和接收操作 。否则，通道会导致先执行发送或接收操作的 goroutine 阻塞等待 。
这种对通道进行发送和接收的交互行为本身就是同步的 。其中任意一个操作都无法离开另一个操作单独存在 。
阻塞：由于某种原因数据没有到达，当前协程（线程）持续处于等待状态 ， 直到条件满足，才接触阻塞 。
同步：在两个或多个协程（线程）间，保持数据内容一致性的机制 。
下图展示两个 goroutine 如何利用无缓冲的通道来共享一个值：
在第 1 步，两个 goroutine 都到达通道，但哪个都没有开始执行发送或者接收 。
在第 2 步，左侧的 goroutine 将它的手伸进了通道 ， 这模拟了向通道发送数据的行为 。这时，这个 goroutine 会在通道中被锁?。?直到交换完成 。
在第 3 步，右侧的 goroutine 将它的手放入通道，这模拟了从通道里接收数据 。这个 goroutine 一样也会在通道中被锁?。钡浇换煌瓿?。
在第 4 步和第 5 步，进行交换，并最终，在第 6 步，两个 goroutine 都将它们的手从通道里拿出来，这模拟了被锁住的 goroutine 得到释放 。两个 goroutine 现在都可以去做别的事情了 。
如果没有指定缓冲区容量，那么该通道就是同步的，因此会阻塞到发送者准备好发送和接收者准备好接收 。
无缓冲channel： —— 同步通信
golang使用Nsq1. 介绍
最近在研究一些消息中间件，常用的MQ如RabbitMQ,ActiveMQ,Kafka等 。NSQ是一个基于Go语言的分布式实时消息平台，它基于MIT开源协议发布，由bitly公司开源出来的一款简单易用的消息中间件 。
官方和第三方还为NSQ开发了众多客户端功能库，如官方提供的基于HTTP的nsqd、Go客户端go-nsq、Python客户端pynsq、基于Node.js的JavaScript客户端nsqjs、异步C客户端libnsq、Java客户端nsq-java以及基于各种语言的众多第三方客户端功能库 。
1.1 Features
1). Distributed
NSQ提供了分布式的，去中心化，且没有单点故障的拓扑结构，稳定的消息传输发布保障，能够具有高容错和HA（高可用）特性 。
2). Scalable易于扩展
NSQ支持水平扩展，没有中心化的brokers 。内置的发现服务简化了在集群中增加节点 。同时支持pub-sub和load-balanced 的消息分发 。
3). Ops Friendly
NSQ非常容易配置和部署，生来就绑定了一个管理界面 。二进制包没有运行时依赖 。官方有Docker image 。
4.Integrated高度集成
官方的 Go 和 Python库都有提供 。而且为大多数语言提供了库 。
1.2 组件
1.3 拓扑结构
NSQ推荐通过他们相应的nsqd实例使用协同定位发布者，这意味着即使面对网络分区，消息也会被保存在本地，直到它们被一个消费者读取 。更重要的是，发布者不必去发现其他的nsqd节点 ， 他们总是可以向本地实例发布消息 。
NSQ
首先，一个发布者向它的本地nsqd发送消息，要做到这点 ， 首先要先打开一个连接 ， 然后发送一个包含topic和消息主体的发布命令，在这种情况下，我们将消息发布到事件topic上以分散到我们不同的worker中 。
事件topic会复制这些消息并且在每一个连接topic的channel上进行排队，在我们的案例中 ， 有三个channel，它们其中之一作为档案channel 。消费者会获取这些消息并且上传到S3 。

推荐阅读


上一篇：chatgpt苹果版在哪里下载，chat下载手机版

下一篇：如何把pdf图片变小，如何把pdf图片变小于800k