队列的概念在 顺序队列 中,而使用循环队列的目的主要是规避假溢出造成的空间浪费,在使用循环队列处理假溢出时,主要有三种解决方案
本文提供后两种解决方案.
顺序队和循环队列是一种特殊的线性表,与顺序栈类似,都是使用一组地址连续的存储单元依次存放自队头到队尾的数据元素,同时附设队头(front)和队尾(rear)两个指针,但我们要明白一点,这个指针并不是指针变量,而是用来表示数组当中元素下标的位置.
本文使用切片来完成的循环队列,由于一开始使用三个参数的make关键字创建切片,在输出的结果中不包含nil值(看起来很舒服),而且在验证的过程中发现使用append()函数时切片内置的cap会发生变化,在消除了种种障碍后得到了一个四不像的循环队列,即设置的指针是顺序队列的指针,但实际上进行的操作是顺序队列的操作.最后是对make()函数和append()函数的一些使用体验和小结,队列的应用放在链队好了.
官方描述(片段)
即切片是一个抽象层,底层是对数组的引用.
当我们使用
构建出来的切片的每个位置的值都被赋为interface类型的初始值nil,但是nil值也是有大小的.
而使用
来进行初始化时,虽然生成的切片中不包含nil值,但是无法通过设置的指针变量来完成入队和出队的操作,只能使用append()函数来进行操作
在go语言中,切片是一片连续的内存空间加上长度与容量的标识,比数组更为常用.使用 append 关键字向切片中追加元素也是常见的切片操作
正是基于此,在使用go语言完成循环队列时,首先想到的就是使用make(type, len, cap)关键字方式完成切片初始化,然后使用append()函数来操作该切片,但这一方式出现了很多问题.在使用append()函数时,切片的cap可能会发生变化,用不好就会发生扩容或收缩.最终造成的结果是一个四不像的结果,入队和出队操作变得与指针变量无关,失去了作为循环队列的意义,用在顺序队列还算合适.
参考博客：
Go语言中的Nil
Golang之nil
Go 语言设计与实现
我们可以看到 gorilla/websocket中的examples中有一个聊天室的demo.
我们进入该项目可以看到里面有这样的一些内容
按照官方的运行方式来运行这个项目
就是这样一个简单的demo.
然后我们去看一下它的具体实现.
在这个项目中首先定义了一个hub的结构体：
我们打开main.go,main函数的源码为：
今天这一节首先会新开一个goroutine,去跑hub的run方法,run方法中一个死循环,不停地去轮询hub中的内容
如果取到了新用户,就加入到clients中,如果取到了信息,就循环所有的client,将信息写到client.send中.
而在请求路径为"/ws"的时候,他会执行一个serveWS的函数.
每当一个新的用户进来之后,首先将连接升级为长连接,然后将当前的client写到register中,由hub.run函数去做处理.然后开启两个goroutine,一个去读client中发送来的数据,一个将数据写入到所有的client中,去发送给用户.
这就是整个聊天室的实现原理.
基本设计思路：
类型转换、类型断言、动态派发.iface,eface.
反射对象具有的方法：
编译优化：
内部实现：
实现 Context 接口有以下几个类型（空实现就忽略了）：
互斥锁的控制逻辑：
设计思路：
（以上为写被读阻塞,下面是读被写阻塞）
总结,读写锁的设计还是非常巧妙的：
WaitGroup 有三个暴露的函数:
部件：
结构：
Once 只暴露了一个方法：
实现：
三个关键点：
细节：
让多协程任务的开始执行时间可控（按顺序或归一）.（Context 是控制结束时间）
设计思路： 通过一个锁和内置的 notifyList 队列实现,Wait() 会生成票据,并将等待协程信息加入链表中,等待控制协程中发送信号通知一个（Signal()）或所有（Boardcast()）等待者（内部实现是通过票据通知的）来控制协程解除阻塞.
暴露四个函数：
实现细节：
包： golang.org/x/sync/errgroup
作用：开启 func() error 函数签名的协程,在同 Group 下协程并发执行过程并收集首次 err 错误.通过 Context 的传入,还可以控制在首次 err 出现时就终止组内各协程.
暴露的方法：
注意问题：
包： "golang.org/x/sync/semaphore"
作用：排队借资源（如钱,有借有还）的一种场景.此包相当于对底层信号量的一种暴露.
设计思路：有一定数量的资源 Weight,每一个 waiter 携带一个 channel 和要借的数量 n.通过队列排队执行借贷.
暴露方法：
包： "golang.org/x/sync/singleflight"
作用：防击穿.瞬时的相同请求只调用一次,response 被所有相同请求共享.
设计思路：按请求的 key 分组（一个 *call 是一个组,用 map 映射存储组）,每个组只进行一次访问,组内每个协程会获得对应结果的一个拷贝.
逻辑：
如有错误,请批评指正.
智能合约调用是实现一个 DApp 的关键,一个完整的 DApp 包括前端、后端、智能合约及区块 链系统,智能合约的调用是连接区块链与前后端的关键.
我们先来了解一下智能合约调用的基础原理.智能合约运行在以太坊节点的 EVM 中.所以呢要 想调用合约必须要访问某个节点.
以后端程序为例,后端服务若想连接节点有两种可能,一种是双 方在同一主机,此时后端连接节点可以采用 本地 IPC(Inter-Process Communication,进 程间通信)机制,也可以采用 RPC(Remote Procedure Call,远程过程调用)机制;另 一种情况是双方不在同一台主机,此时只能采用 RPC 机制进行通信.
接着,我们来了解一下智能合约运行的过程.
智能合约的运行过程是后端服务连接某节点,将 智能合约的调用(交易)发送给节点,节点在验证了交易的合法性后进行全网广播,被矿工打包到 区块中代表此交易得到确认,至此交易才算完成.
就像数据库一样,每个区块链平台都会提供主流 开发语言的 SDK(Software Development Kit,软件开发工具包),由于 Geth 本身就是用 Go 语言 编写的,所以呢若想使用 Go 语言连接节点、发交易,直接在工程内导入 go-ethereum(Geth 源码) 包就可以了,剩下的问题就是流程和 API 的事情了.
最后提醒一下大家,智能合约被调用的两个关键点是节点和 SDK.
此时此刻呢介绍如何使用 Go 语言,借助 go-ethereum 源码库来实现智能合约的调用.这是有固定 步骤的,我们先来说一下总体步骤,以下面的合约为例.
步骤 01:编译合约,获取合约 ABI(Application Binary Interface,应用二进制接口). 单击【ABI】按钮拷贝合约 ABI 信息,将其粘贴到文件 calldemo.abi 中(可使用 Go 语言IDE 创建该文件,文件名可自定义,后缀最好使用 abi).
最好能将 calldemo.abi 单独保存在一个目录下,输入"ls"命令只能看到 calldemo.abi 文件,参 考效果如下:
此时此刻呢设置 module 生效和 GOPROXY,命令如下:
在项目工程内,执行初始化,calldemo 可以自定义名称.
上一节中,我们为每个连接都创建了一个goroutine来读取其中的消息,现在我们将这个读取消息的方法实现一下.
我们在application目录下新建controllers目录,并在其中创建一个MessageController.go文件.
首先我们新建一个MessageController的结构体,内容如下
这个结构体包括两个内容,一个是我们将连接放在数组之后,返回的索引,另一个是连接本身.
这个是具体的方法.
我们首先设置了一下读消息的大小、超时时间以及超时后需要的操作.
超时时间如果设置为0,那么就是永不超时.之前今天这一节直接写0,被告知需要传一个time.Time类型的数据.最终谷歌后才得到了这个值time.Time{}为"0001-01-01 00:00:00 +0000 UTC".
我们将用户手法消息的内容定义为一个结构体,然后将用户的订阅信息的json通过json.unmarshal转换成这个结构体.
之后的switch操作与我们在Swoole中的操作基本雷同,在查询到login之后,调用service中 的login方法来进行注册.
下一节中我们再介绍具体的注册逻辑.
你可以在 GitHub 上找到本项目的源码：concTcp.go.
这个程序的主要逻辑在 handleConnection 函数中,具体实现如下：
首先, main 确保程序至少有一个命令行参数.注意,现有代码并没有检查这个参数是否为有效的 TCP 端口号.不过,如果它是一个无效的 TCP 端口号, net.Listen 就会调用失败,并返回一个错误信息,类似下面这样：
你可以在 维基百科上找到更多关于 nc （即 netcat ）的信息.
via: