GoLang 示例:并发回声服务器

服务器端

package main

import (
    "bufio"
    "fmt"
    "log"
    "net"
    "strings"
    "time"
)

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

func handleConn(c net.Conn){
    input := bufio.NewScanner(c)
    for input.Scan(){
        echo(c,input.Text(),1*time.Second)
    }
}
func echo(c net.Conn,shout string,delay time.Duration){
    fmt.Fprintln(c,"\t",strings.ToUpper(shout))
    time.Sleep(delay)
    fmt.Fprintln(c,"\t",shout)
    time.Sleep(delay)
    fmt.Fprintln(c,"\t",strings.ToLower(shout))
}

客户端

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()
    go mustCopy(os.Stdout,conn)
    mustCopy(conn,os.Stdin)
    
}

func mustCopy(dst io.Writer, src io.Reader)  {
    if _,err:=io.Copy(dst,src);err!=nil {
        log.Fatal(err)
    }
}

工作原理

服务端向外提供以下服务

• 开启一个tcp服务器listenner
• tcp服务器监听请求产生连接conn ->for
• 使用外部函数处理conn ->for
  外部处理函数工作流程
• 使用NewScanner(conn)获取input
• 循环执行echo()函数直到没有获取到新的input为止

客户端向服务端发送请求原理

• 开启一个客户端的连接conn
• 获取输入赋值给conn
  *在另一个goroutine 将处理后的结果输出到客户端

完成！