我一个TCP服务，希望从外部关闭Listener，但这样就在listener.Close()与listener.Accept()之间产生了race。请教有什么好的解决办法？
简单的示例代码如下, 加"-race"参数运行，再ctrl+c退出运行，就会报race问题：
```
package main
import (
"log"
"net"
"os"
"os/signal"
"syscall"
"time"
)
var listener *net.TCPListener
// tcp服务
func tcpServer() {
addr, err := net.ResolveTCPAddr("tcp4", ":6666")
if err != nil {
log.Fatalln(err)
}
listener, err = net.ListenTCP("tcp4", addr)
if err != nil {
log.Fatalln(err)
}
for {
c, err := listener.AcceptTCP()
if err != nil {
if err.(*net.OpError).Err == net.ErrClosed {
log.Println("listener closed")
return
}
log.Println(err)
continue
}
connHandler(c)
}
}
// 新连接处理
func connHandler(c *net.TCPConn) {
defer func() {
c.Close()
log.Printf("%s closed", c.RemoteAddr().String())
}()
log.Printf("New connection: %s", c.RemoteAddr().String())
buf := make([]byte, 128)
for {
n, err := c.Read(buf)
if err != nil {
return
}
log.Println(buf[:n])
}
}
// 关闭listener
func listenerClose() {
if listener != nil {
listener.Close()
}
}
func main() {
sigs := make(chan os.Signal, 1)
signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
go tcpServer()
<-sigs
listenerClose()
time.Sleep(time.Millisecond * 200)
}
```
<a href="/user/xwszt" title="@xwszt">@xwszt</a> 其实最初没把Listener做成全局变量，也不存在争用问题。前天在做代码审查时，发现一个专门处理服务关闭事件的协程，基本是空闲的，而项目里有许多Listener，就想把这些Listener都统一到这个协程里来作通知关闭管理，所以才改成全局变量的。
#9
更多评论
jan-bar
想要拥有，必定付出。
我的写法核心就是让`Accept()`操作设置超时时间，保证可以执行其他代码。
或者关闭代码就在你的程序里面模拟tcp连接发送特殊字符，然后服务端收到特殊字符就走退出逻辑。
```go
package main
import (
"context"
"log"
"net"
"os"
"os/signal"
"syscall"
"time"
)
// tcp服务
func tcpServer(ctx context.Context) {
addr, err := net.ResolveTCPAddr("tcp4", ":6666")
if err != nil {
log.Fatalln(err)
}
listener, err := net.ListenTCP("tcp4", addr)
if err != nil {
log.Fatalln(err)
}
for {
select {
case <-ctx.Done():
err = listener.Close()
if err != nil {
log.Fatalln(err)
}
return
default:
// 控制超时时间,让代码有机会执行ctx.Done()
_ = listener.SetDeadline(time.Now().Add(time.Second))
c, err := listener.AcceptTCP()
if err != nil {
if opErr, ok := err.(*net.OpError); ok {
if opErr.Timeout() {
continue
}
if opErr.Err == net.ErrClosed {
log.Println("listener closed")
return
}
}
log.Println(err)
continue
}
connHandler(c)
}
}
}
// 新连接处理
func connHandler(c *net.TCPConn) {
defer func() {
c.Close()
log.Printf("%s closed", c.RemoteAddr().String())
}()
log.Printf("New connection: %s", c.RemoteAddr().String())
buf := make([]byte, 128)
for {
n, err := c.Read(buf)
if err != nil {
return
}
log.Println(buf[:n])
}
}
func main() {
sigs := make(chan os.Signal, 1)
signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
ctx, cancel := context.WithCancel(context.Background())
go tcpServer(ctx)
<-sigs
cancel()
time.Sleep(time.Millisecond * 200)
}
```
#1
<a href="/user/jan-bar" title="@jan-bar">@jan-bar</a> 谢谢。目前只有这个办法了。
#2
今日阅读排行
一周阅读排行