go内置库函数实现client与server数据的发送接收

功能:客户端持续写入数据,直到输入exit退出,服务端读取数据并打印
注意:server和client目录在同一层级

服务端

server/main

package main

import (
	"fmt"
	"net"
)

func main() {
	listen, err := net.Listen("tcp", "0.0.0.0:8080")
	if err != nil {
		fmt.Printf("err: %v\n", err)
		return
	}
	fmt.Println("server is listening")
	defer listen.Close()
	for {
		conn, err2 := listen.Accept()
		if err2 != nil {
			fmt.Printf("err2: %v\n", err2)
			return
		}
		fmt.Printf("server: %v\n", conn.LocalAddr())
		go readData(conn)
	}
}

func readData(conn net.Conn) {
	defer conn.Close()
	buf := make([]byte, 1024)
	for {
		n, err := conn.Read(buf)
		if err != nil {
			fmt.Printf("err: %v\n", err)
			return
		}
		fmt.Println("读取了", n, "字节数据")
		fmt.Println("buf:", string(buf[:n]))
	}
}

客户端

client/main
go开启协程,数据写入结束向管道输入信号,主线程获取信号,退出。否则主线程运行结束会直接退出

package main

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

var exitchan chan bool

func main() {
	fmt.Println("client is wating to connect")
	conn, err := net.Dial("tcp", "192.168.0.1:8080")
	if err != nil {
		fmt.Printf("err: %v\n", err)
		return
	}
	go writeData(conn)
	if <-exitchan {
		fmt.Print("client exit")
	}
}

func writeData(conn net.Conn) {
	defer conn.Close()
	reader := bufio.NewReader(os.Stdin)
	len := 0
	for {
		line, err := reader.ReadString('\n')
		if err != nil {
			return
		}
		line = strings.Trim(line, "\r\n")
		len, err = conn.Write([]byte(line))
		if err != nil {
			return
		}
		if line == "exit" {
			break
		}
		fmt.Println("写入", len, "字节数据")
	}
	fmt.Println("client:", conn.RemoteAddr())
	exitchan <- true
}

相关推荐

  1. go函数实现clientserver数据发送接收

    2024-02-19 05:52:03       31 阅读
  2. awk数值函数

    2024-02-19 05:52:03       29 阅读
  3. IDEAHTTP CLIENT

    2024-02-19 05:52:03       28 阅读
  4. PostgreSQL 函数

    2024-02-19 05:52:03       6 阅读
  5. 8个实用Python函数

    2024-02-19 05:52:03       39 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-02-19 05:52:03       18 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-02-19 05:52:03       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-02-19 05:52:03       18 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-02-19 05:52:03       20 阅读

热门阅读

  1. 【状态估计】深度传感器与深度估计算法(1/3)

    2024-02-19 05:52:03       30 阅读
  2. 关于怎么监督机器学习训练的进度

    2024-02-19 05:52:03       32 阅读
  3. 学习数据接构和算法的第10天

    2024-02-19 05:52:03       26 阅读
  4. Swift 指北

    2024-02-19 05:52:03       28 阅读
  5. DP进阶之最长递增子序列

    2024-02-19 05:52:03       39 阅读
  6. 【npm】npm镜像源及命令

    2024-02-19 05:52:03       29 阅读
  7. opencv进行人脸识别

    2024-02-19 05:52:03       28 阅读
  8. 企业面临的网络安全风险及应对策略

    2024-02-19 05:52:03       25 阅读
  9. 洛谷 P8630 [蓝桥杯 2015 国 B] 密文搜索

    2024-02-19 05:52:03       26 阅读
  10. npm详解:掌握package.json配置

    2024-02-19 05:52:03       30 阅读