package main

import (
	"fmt"
	"net"
)

func main () {
	fmt.Println("start server...")

	//Listen来创建服务端
	ln, err := net.Listen("tcp", ":10010")

	if err != nil {
		fmt.Println("listen failed, err:", err)
		return
	}

	for {
		conn, err := ln.Accept()
		if err != nil {
			fmt.Println("accept failed, err:", err)
			continue
		}

		//开启新的gouroutine 去处理请求
		//每个请求开启一个goroutine
		go process(conn)
	}
}

func process (conn net.Conn) {
	defer conn.Close()

	for {
		buf := make([]byte, 512)
		_, err := conn.Read(buf)

		if err != nil {
			fmt.Println("read failed, err:", err)
			return
		}

		fmt.Println("read:", string(buf))
	}
}

//客户端程序
package main

import (
	"fmt"
	"os"
	"strings"
	"bufio"
	"net"
)

func main () {
	conn, err := net.Dial("tcp", "localhost:10010")

	if err != nil {
		fmt.Println("Erroring dialing", err.Error())
		return
	}

	defer conn.Close()

	inputReader := bufio.NewReader(os.Stdin)

	for{
		input, _ := inputReader.ReadString(\'\n\')
		trimedinput := strings.Trim(input, "\r\n")

		if trimedinput == "Q" {
			return
		}

		_, err := conn.Write([]byte(trimedinput))

		if err != nil {
			return
		}
	}
}