Go语言示例：并发的Clock服务

最新推荐文章于 2024-05-18 09:58:27 发布

「已注销」

最新推荐文章于 2024-05-18 09:58:27 发布

阅读量527

点赞数

分类专栏： Go 文章标签： golang

本文链接：https://blog.csdn.net/Deep___Learning/article/details/107410427

版权

Go 专栏收录该内容

7 篇文章

订阅专栏

本文介绍了如何使用Go语言创建一个并发的Clock服务器。原始版本的服务器只能顺序处理客户端请求，而改进后的版本能同时服务于多个客户端，提高了并发性能。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

写在前面： 我是「虐猫人薛定谔」，一个不满足于现状，有梦想，有追求的00后
$\quad$
本博客主要记录和分享自己毕生所学的知识，欢迎关注，第一时间获取更新。
$\quad$
不忘初心，方得始终。
$\quad$

❤❤❤❤❤❤❤❤❤❤

顺序执行的Clock服务器

这是一个顺序执行的时钟服务器，它每隔一秒钟就会将当前系统时间写到客户端。

// Clock1 is a TCP server that periodically writes the time.
package main

import (
	"io"
	"log"
	"net"
	"time"
)

func main() {
	listener, err := net.Listen("tcp", "localhost:8080")
	if err != nil {
		log.Fatal(err)
	}
	for {
		conn, err := listener.Accept()
		if err != nil {
			log.Print(err)
			continue
		}
		handleConn(conn)
	}
}

func handleConn(c net.Conn) {
	defer c.Close()
	for {
		_, err := io.WriteString(c, time.Now().Format("15:04:05\n"))
		if err != nil {
			return
		}
		time.Sleep(1 * time.Second)
	}
}

在这里插入图片描述

从结果中，我们可以看到，如果用两个客户端去连接该时钟服务器，该服务器只会响应其中一个客户端，只有当关闭第一个客户端，第二个客户端才能接收服务器的响应，即第二个客户端必须等待第一个客户端完成工作，之所以出现这种情况，是因为我们的时钟服务器同一时间只能处理一个客户端的连接，这显然不是我们想要的，下面我们对其进行改进，使其能够同时支持多个客户端。

支持并发的Clock服务器

package main

import (
	"io"
	"log"
	"net"
	"time"
)

func main() {
	listener, err := net.Listen("tcp", "localhost:8080")
	if err != nil {
		log.Fatal(err)
	}
	for {
		conn, err := listener.Accept()
		if err != nil {
			log.Print(err)
			continue
		}
		go handleConn1(conn)
	}
}

func handleConn1(c net.Conn) {
	defer c.Close()
	for {
		_, err := io.WriteString(c, time.Now().Format("15:04:05\n"))
		if err != nil {
			return
		}
		time.Sleep(1 * time.Second)
	}
}