在Go中构建并发TCP服务器

TCP和UDP服务器无处不在，通过TCP / IP网络为网络客户端提供服务。在本文中，我将解释如何使用Go编程语言开发并发TCP服务器，该服务器返回随机数。对于来自TCP客户端的每个传入连接，TCP服务器将启动一个新的goroutine来处理该请求。

处理TCP连接

程序的逻辑可以在handleConnection()函数的Go代码中找到，该代码的实现如下：

如果TCP客户端发送“ STOP”字符串，则为该特定TCP客户端提供服务的goroutine将终止；否则，它将终止。否则，TCP服务器将随机数发送回TCP客户端。该for循环确保TCP客户端的服务时间与TCP客户端所需的时间一样长。for循环中的Go代码使用逐行从TCP客户端读取数据，bufio.NewReader(c).ReadString('')并使用发送回数据c.Write([]byte(string(result)))。(您可能会发现网络标准Go软件包文档很有帮助。)

并发

该main()函数的实现告诉TCP服务器每次必须为TCP客户端提供服务时都要启动一个新的goroutine：

首先，请main()确保该程序至少有一个命令行参数。请注意，现有代码不会检查给定的命令行参数是否为有效的TCP端口号。但是，如果给定的值不是有效的TCP端口号，则对的调用net.Listen()将失败，并显示类似于以下内容的错误消息：

该net.Listen()调用用于告诉Go程序接受网络连接，从而充当服务器。的返回值net.Listen()是的net.Conn类型，它实现了io.Reader与io.Writer接口。该main()函数还调用该rand.Seed()函数以初始化随机数生成器。最后，该for循环允许程序继续使用Accept()将由handleConnection()函数实例执行的新TCP客户端，该实例将作为goroutine执行。

net.Listen()的第一个参数

该net.Listen()函数的第一个参数定义将使用的网络类型，而第二个参数定义服务器地址以及服务器将侦听的端口号。第一个参数的有效值为tcp，tcp4(仅IPv4)，tcp6(仅IPv6)，udp，udp4(仅IPv4)，udp6(仅IPv6)，ip，ip4(仅IPv4)，ip6(仅限IPv6)，Unix(Unix套接字)，Unixgram和Unixpacket。

运行中的并发TCP服务器

concTCP.go需要一个命令行参数，这是它将侦听的端口号。在为TCP客户端提供服务时，将从concTCP.go获得的输出与以下内容类似：

输出netstat(1)可以验证concTCP.go在侦听更多连接时是否服务于多个TCP客户端：

前面命令输出的最后一行告诉我们，有一个进程正在侦听端口8001，这意味着您仍然可以连接到TCP端口8001。前两行验证存在已建立的TCP网络连接使用端口号8001和62556。类似地，第三和第四行验证是否存在另一个使用端口号8001和62554的已建立TCP连接。

此图显示了服务多个TCP客户端时concTCP.go的输出：

类似地，下图显示了使用该nc(1)实用程序实现的两个TCP客户端的输出：

总结

因此，您刚刚学习了如何开发并发TCP服务器，该服务器使用大约65行Go代码生成随机数，这真是令人印象深刻！如果您希望TCP服务器执行其他工作，只需更改handleConnection()功能的实现即可。您可以在GitHub上找到这个项目concTCP.go{https://github.com/mactsouk/opensource.com}。