示例:并发时钟服务器
【示例】顺序时钟服务器,它以每秒钟一次的频率向客户端发送当前时间,代码如下所示:
// clock1 是一个定期报告时间的 TCP 服务器 package main import ( "io" "log" "net" "time" ) func main() { listener, err := net.Listen("tcp", "localhost:8000") 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) } }Listen 函数创建一个 net.Listener 对象,它在一个网络端口上监听进来的连接,这里是 TCP 端口 localhost:8000。监听器的 Accept 方法被阻塞,直到有连接请求进来,然后返回 net.Conn 对象来代表一个连接。
handleConn 函数处理一个完整的客户连接。在循环里,它将 time.Now() 获取的当前时间发送给客户端。因为 net.Conn 满足 io.Writer 接口,所以可以直接向它进行写入。
当写入失败时循环结束,很多时候是客户端断开连接,这时 handleconn 函数使用延迟的 Close 调用关闭自己这边的连接,然后继续等待下一个连接请求。
time.Time.Format 方法提供了格式化日期和时间信息的方式。它的参数是一个模板,指示如何格式化一个参考时间,具体如 Mon Jan 2 03:04:05PM 2006 UTC-0700 这样的形式。参考时间有 8 个部分(本周第几天、月、本月第几天,等等)。
它们可以以任意的组合和对应数目的格式化字符出现在格式化模板中,所选择的日期和时间将通过所选择的格式进行显示。这里只使用时间的小时、分钟和秒部分。time 包定义了许多标准时间格式的模板,如 time.RFC1123。相反,当解析一个代表时间的字符串的时候使用相同的机制。
为了连接到服务器,需要一个像 nc("netcat") 这样的程序,以及一个用来操作网络连接的标准工具:
$ go build gopl.io/ch8/clockl
$ ./clock1 &
$ nc localhost 8000
13:58:54
13:58:55
13:58:56
13:58:57
^C
// netcat1是一个只读的 TCP 客户端程序 package main import ( "io" "log" "net" "os" ) func main() { conn, err : = net.Dial("tcp", "localhost:8000") if err != nil { log.Fatal(err) } defer conn.Close() mustCopy(os.Stdout, conn) } func mustCopy(dst io.Writer, src io.Reader) { if _, err := io.Copy(dst, src); err != nil { log.Fatal(err) } }这个程序从网络连接中读取,然后写到标准输出,直到到达 EOF 或者岀错。mustCopy 函数是这一节的多个例子中使用的一个实用程序。在不同的终端上同时运行两个客户端,一个显示在左边,一个在右边:
$ go build gopl.io/ch8/netcat1
$ ./netcat1
13:58:54 $ ./netcat1
13:58:55
13:58:56
^C
13:58:57
13:58:58
13:58:59
^C
$ killall clock1
第二个客户端必须等到第一个结束才能正常工作,因为服务器是顺序的,一次只能处理一个客户请求。让服务器支持并发只需要一个很小的改变:在调用 handleconn 的地方添加一个 go 关键字,使它在自己的 goroutine 内执行。
for { conn, err := listener.Accept() if err != nil { log.Print(err) //例如,连接中止 continue } go handleConn(conn) // 并发处理连接 }现在,多个客户端可以同时接收到时间:
$ go build gopl.io/ch8/clock2
$ ./clock2 &
$ go build gopl.io/ch8/netcat1
$ ./netcat1
14:02:54 $ ./netcat1
14:02:55 14:02:55
14:02:56 14:02:56
14:02:57 ^C
14:02:58
14:02:59 $ ./netcat1
14:03:00 14:03:00
14:03:01 14:03:01
^C 14:03:02
^C
$ killall clock2
所有教程
- C语言入门
- C语言编译器
- C语言项目案例
- 数据结构
- C++
- STL
- C++11
- socket
- GCC
- GDB
- Makefile
- OpenCV
- Qt教程
- Unity 3D
- UE4
- 游戏引擎
- Python
- Python并发编程
- TensorFlow
- Django
- NumPy
- Linux
- Shell
- Java教程
- 设计模式
- Java Swing
- Servlet
- JSP教程
- Struts2
- Maven
- Spring
- Spring MVC
- Spring Boot
- Spring Cloud
- Hibernate
- Mybatis
- MySQL教程
- MySQL函数
- NoSQL
- Redis
- MongoDB
- HBase
- Go语言
- C#
- MATLAB
- JavaScript
- Bootstrap
- HTML
- CSS教程
- PHP
- 汇编语言
- TCP/IP
- vi命令
- Android教程
- 区块链
- Docker
- 大数据
- 云计算