go语言学习笔记之十---网络编程

package main

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

func dealConn(conn net.Conn) {

	defer conn.Close() //此函数结束时，关闭连接套接字

	//conn.RemoteAddr().String()：连接客服端的网络地址
	ipAddr := conn.RemoteAddr().String()
	fmt.Println(ipAddr, "连接成功")

	buf := make([]byte, 1024) //缓冲区，用于接收客户端发送的数据

	for {
		//阻塞等待用户发送的数据
		n, err := conn.Read(buf) //n代码接收数据的长度
		if err != nil {
			fmt.Println(err)
			return
		}
		//切片截取，只截取有效数据
		result := buf[:n]
		fmt.Printf("接收到数据来自[%s]==>[%d]:%s\n", ipAddr, n, string(result))
		if "exit" == string(result) { //如果对方发送"exit"，退出此链接
			fmt.Println(ipAddr, "退出连接")
			return
		}

		//把接收到的数据转换为大写，再给客户端发送
		conn.Write([]byte(strings.ToUpper(string(result))))
	}
}

func main() {
	//创建、监听socket
	listenner, err := net.Listen("tcp", "127.0.0.1:8000")
	if err != nil {
		log.Fatal(err) //log.Fatal()会产生panic
	}

	defer listenner.Close()

	for {
		conn, err := listenner.Accept() //阻塞等待客户端连接
		if err != nil {
			log.Println(err)
			continue
		}

		go dealConn(conn)
	}
}

package main

import (
	"fmt"
	"log"
	"net"
)

func main() {
	//客户端主动连接服务器
	conn, err := net.Dial("tcp", "127.0.0.1:8000")
	if err != nil {
		log.Fatal(err) //log.Fatal()会产生panic
		return
	}

	defer conn.Close() //关闭

	buf := make([]byte, 1024) //缓冲区
	for {
		fmt.Printf("请输入发送的内容：")
		fmt.Scan(&buf)
		fmt.Printf("发送的内容：%s\n", string(buf))

		//发送数据
		conn.Write(buf)

		//阻塞等待服务器回复的数据
		n, err := conn.Read(buf) //n代码接收数据的长度
		if err != nil {
			fmt.Println(err)
			return
		}

		//切片截取，只截取有效数据
		result := buf[:n]
		fmt.Printf("接收到数据[%d]:%s\n", n, string(result))
	}
}

package main

import (
	"fmt"
	"log"
	"net"
)

func main() {
	//创建、监听socket
	listenner, err := net.Listen("tcp", "127.0.0.1:8000")
	if err != nil {
		log.Fatal(err) //log.Fatal()会产生panic
	}

	defer listenner.Close()

	conn, err := listenner.Accept() //阻塞等待客户端连接
	if err != nil {
		log.Println(err)
		return
	}

	defer conn.Close() //此函数结束时，关闭连接套接字

	//conn.RemoteAddr().String()：连接客服端的网络地址
	ipAddr := conn.RemoteAddr().String()
	fmt.Println(ipAddr, "连接成功")

	buf := make([]byte, 4096) //缓冲区，用于接收客户端发送的数据

	//阻塞等待用户发送的数据
	n, err := conn.Read(buf) //n代码接收数据的长度
	if err != nil {
		fmt.Println(err)
		return
	}

	//切片截取，只截取有效数据
	result := buf[:n]
	fmt.Printf("接收到数据来自[%s]==>:\n%s\n", ipAddr, string(result))
}

package main

import (
	"fmt"
	"net/http"
)

//服务端编写的业务逻辑处理程序
func myHandler(w http.ResponseWriter, r *http.Request) {
	fmt.Fprintln(w, "hello world")
}

func main() {
	http.HandleFunc("/go", myHandler)

	//在指定的地址进行监听，开启一个HTTP
	http.ListenAndServe("127.0.0.1:8000", nil)
}

package main

import (
	"fmt"
	"io"
	"log"
	"net/http"
)

func main() {

	//get方式请求一个资源
	//resp, err := http.Get("http://www.baidu.com")
	//resp, err := http.Get("http://www.neihan8.com/article/index.html")
	resp, err := http.Get("http://127.0.0.1:8000/go")
	if err != nil {
		log.Println(err)
		return
	}

	defer resp.Body.Close() //关闭

	fmt.Println("header = ", resp.Header)
	fmt.Printf("resp status %s\nstatusCode %d\n", resp.Status, resp.StatusCode)
	fmt.Printf("body type = %T\n", resp.Body)

	buf := make([]byte, 2048) //切片缓冲区
	var tmp string

	for {
		n, err := resp.Body.Read(buf) //读取body包内容
		if err != nil && err != io.EOF {
			fmt.Println(err)
			return
		}

		if n == 0 {
			fmt.Println("读取内容结束")
			break
		}
		tmp += string(buf[:n]) //累加读取的内容
	}

	fmt.Println("buf = ", string(tmp))
}