共有两台服务器A跟B，它们使用一条grpc长链接进行交互，A是grpc服务端，在公网；B是客户端，在内网。
服务器A的代码里有两个协程，分别监听http和grpc，用一个同步channel进行通信。
我的业务流程：
1、用户通过http接口访问A，A需要调用B的程序，此时使用Send(*Response) error把必要的参数发送过去；
2、B通过Recv()监听到A发来的请示，把运算结果通过Send()发送回A；
3、A通过Recv()收到运算结果，把结果输入到同步channel，http服务结束同步阻塞，返回http response给用户。
现在我要在步骤1加上30秒超时的限制，却出现了奇怪的问题，伪代码如下：
```
A.Send("data...")
go func() {
time.Sleep(30e9)
timeoutChan <- true
}()
select {
case <-timeoutChan:
// 返回超时错误信息
case resp := <-respChan:
// 正常返回数据
}
```
按照我的想法，应该是用户访问A的http接口时，如果超过30秒，会得到个超时错误。但却产生以下问题，有并发请示时（假设恰好请示1和请示2），请示1得到的http response是请示2的运算结果，请示2得到的http response是请示1的运算结果。
我回滚到原代码，（即去掉了超时限制功能，没有上边的go func(){time.Sleep()}和select... case...)，只使用同步channel一直阻塞等待返回结果，进行压力测试，并不会出上以上问题，http request跟response都能对应。所以现在想不通，为何select... case...会出现以上问题，我需要做什么改进。
czyt
云在青天水在瓶
对于chan的timeout 参考下面的例子
```go
package main
import (
"fmt"
"os"
"time"
)
func main() {
notify := make(chan int64, 1)
timeoutCnt := 0
go func() {
counter := 0
for {
time.Sleep(1 * time.Second)
notify <- time.Now().UnixNano()
counter++
if counter > 30 {
break
}
}
}()
for {
select {
case currentTime := <-notify:
fmt.Println(currentTime)
case <-time.After(5 * time.Second):
fmt.Println("time out")
timeoutCnt++
if timeoutCnt > 3 {
os.Exit(0)
}
}
}
}
```
#1
今日阅读排行
一周阅读排行