GO語言的進階之路-網絡編程之socket

　　　　　　　　　　　　　　　　　　　　　　　　　　GO語言的進階之路-網絡編程之socket

　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　作者：尹正傑

版權聲明：原創作品，謝絕轉載！否則將追究法律責任。

 

一.什么是socket;

　　在說socket之前，我們要對兩個概念要有所了解，就是IP和端口。

1.什么是IP；

　　IP地址是我們進行TCP/IP通訊的基礎，每個鏈接到網絡的計算機都必須有一個IP地址。在這里我不打算給大家說IPV4和IPV6，也不打算說主機位和網絡位。

　　我們可以簡單的理解，在局域網中，IP就是用來標識主機的。（大家不要鑽牛角尖說NAT這種情況，我們在這里是忽略的。）

 

2.什么是端口；

　　如果說IP是用來標識主機的，那么端口就是用來標識這台主機的所有服務。

　　這樣我們就方便理解了，端口是用來標識服務的，只要主機的服務啟動，然后我們訪問主機的對應端口就能被提供服務。歡聚話說，局域網中如果別人知道你IP和端口，就能訪問到的你的服務了（前提下是別人的主機和你的主機是要互通的。）

 

3.什么是socket;

　　網絡上的兩個程序通過一個雙向的通信連接實現數據的交換，這個連接的一端稱為一個socket。

　　建立網絡通信連接至少要一對端口號(socket)。socket本質是編程接口(API)，對TCP/IP的封裝，TCP/IP也要提供可供程序員做網絡開發所用的接口，這就是Socket編程接口；HTTP是轎車，提供了封裝或者顯示數據的具體形式；Socket是發動機，提供了網絡通信的能力。

　　Socket的英文原義是“孔”或“插座”。作為BSD UNIX的進程通信機制，取后一種意思。通常也稱作"套接字"，用於描述IP地址和端口，是一個通信鏈的句柄，可以用來實現不同虛擬機或不同計算機之間的通信。每種服務都打開一個Socket，並綁定到一個端口上，不同的端口對應於不同的服務。Socket正如其英文原意那樣，像一個多孔插座。插座是用來給插頭提供一個接口讓其通電的，此時我們就可以將插座當做一個服務端,不同的插頭當做客戶端。

 
二.客戶端Socket；

1.串行指定讀取客戶端返回內容大小；(這種方法我不推薦使用！我推薦使用的是后三種方式讀取。請看下面的備注。)

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "fmt"
    "reflect"
    "io"
)

func main() {
    addr := "wwww.baidu.com:80" //定義主機名
    conn,err := net.Dial("tcp",addr) //撥號操作，需要指定協議。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("訪問公網IP地址是：",conn.RemoteAddr().String()) /*獲取“conn”中的公網地址。注意：最好是加上后面的String方法，因為他們的那些是不一樣的喲·當然你打印的時候
    可以不加輸出結果是一樣的，但是你的內心是不一樣的喲！*/
    fmt.Printf("客戶端鏈接的地址及端口是：%v\n",conn.LocalAddr()) //獲取到本地的訪問地址和端口。
    fmt.Println("“conn.LocalAddr()”所對應的數據類型是：",reflect.TypeOf(conn.LocalAddr()))
    fmt.Println("“conn.RemoteAddr().String()”所對應的數據類型是：",reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服務端發送數據。用n接受返回的數據大小，用err接受錯誤信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("向服務端發送的數據大小是:",n)

    buf := make([]byte,1024) //定義一個切片的長度是1024。

    n,err = conn.Read(buf) //接收到的內容大小。

    if err != nil && err != io.EOF {  //io.EOF在網絡編程中表示對端把鏈接關閉了。
        log.Fatal(err)
    }
    fmt.Println(string(buf[:n])) //將接受的內容都讀取出來。
    conn.Close()  //斷開TCP鏈接。
}



#以上代碼輸出結果如下：
訪問公網IP地址是： 111.13.101.208:80
客戶端鏈接的地址及端口是：172.16.3.210:49568
“conn.LocalAddr()”所對應的數據類型是： *net.TCPAddr
“conn.RemoteAddr().String()”所對應的數據類型是： string
向服務端發送的數據大小是: 18
HTTP/1.1 400 Bad Request
Date: Mon, 31 Jul 2017 06:22:41 GMT
Server: Apache
Content-Length: 226
Connection: Keep-Alive
Content-Type: text/html; charset=iso-8859-1

 　　備注：io.Copy不會主動調用close，io.Copy結束的條件是reader得到EOF。感興趣的可以看下源碼。

func copyBuffer(dst Writer, src Reader, buf []byte) (written int64, err error) {
      // If the reader has a WriteTo method, use it to do the copy.
      // Avoids an allocation and a copy.
      if wt, ok := src.(WriterTo); ok {
          return wt.WriteTo(dst)
      }
      // Similarly, if the writer has a ReadFrom method, use it to do the copy.
      if rt, ok := dst.(ReaderFrom); ok {
          return rt.ReadFrom(src)
      }
      if buf == nil {
          buf = make([]byte, 32*1024)
      }
      for {
          nr, er := src.Read(buf)
          if nr > 0 {
              nw, ew := dst.Write(buf[0:nr])
              if nw > 0 {
                  written += int64(nw)
              }
              if ew != nil {
                  err = ew
                  break
              }
              if nr != nw {
                  err = ErrShortWrite
                  break
              }
          }
          if er != nil {
              if er != EOF {
                  err = er
              }
              break
          }
      }
      return written, err
  }

 

2.按照指定大小循環讀取;

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "fmt"
    "reflect"
    "io"
)

func main() {
    addr := "wwww.baidu.com:80" //定義主機名
    conn,err := net.Dial("tcp",addr) //撥號操作，需要指定協議。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(conn.RemoteAddr().String()) //最好是加上后面的String方法，因為他們的那些是不一樣的喲·當然你打印的時候可以不加。
    fmt.Println(conn.LocalAddr())
    fmt.Println(reflect.TypeOf(conn.LocalAddr()))
    fmt.Println(reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服務端發送數據。用n接受返回的數據大小，用err接受錯誤信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("寫入的大小是:",n)

    buf := make([]byte,10) //定義一個切片的長度是1024。

    for  {
        n,err = conn.Read(buf) //接收到的內容大小。
        if err == io.EOF {
            conn.Close()
        }
        fmt.Print(string(buf[:n]))
    }

    fmt.Println(string(buf[:n])) //將接受的內容都讀取出來。

}




#以上代碼輸出結果如下：
111.13.101.208:80
172.16.3.210:63838
*net.TCPAddr
string
寫入的大小是: 18
HTTP/1.1 400 Bad Request
Date: Mon, 31 Jul 2017 10:38:42 GMT
Server: Apache
Content-Length: 226
Connection: Keep-Alive
Content-Type: text/html; charset=iso-8859-1

<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>400 Bad Request</title>
</head><body>
<h1>Bad Request</h1>
<p>Your browser sent a request that this server could not understand.<br />
</p>
</body></html>

 

3.按行讀取；

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "fmt"
    "reflect"
    "io"
    "bufio"
)

func main() {
    addr := "wwww.baidu.com:80" //定義主機名
    conn,err := net.Dial("tcp",addr) //撥號操作，需要指定協議。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(conn.RemoteAddr().String()) //最好是加上后面的String方法，因為他們的那些是不一樣的喲·當然你打印的時候可以不加。
    fmt.Println(conn.LocalAddr())
    fmt.Println(reflect.TypeOf(conn.LocalAddr()))
    fmt.Println(reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服務端發送數據。用n接受返回的數據大小，用err接受錯誤信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("寫入的大小是:",n)

    r := bufio.NewReader(conn) //將這個鏈接（connection）包裝以下。將conn的內容都放入r中，但是沒有進行讀取，讓步我們一會對其進行操作。
    for  {
        line,err := r.ReadString('\n') //將r的內容也就是conn的數據按照換行符進行讀取。
        if err == io.EOF {
            conn.Close()
        }
        fmt.Print(line)
    }


}




#以上代碼輸出結果如下：
111.13.101.208:80
172.16.3.210:64613
*net.TCPAddr
string
寫入的大小是: 18
HTTP/1.1 400 Bad Request
Date: Mon, 31 Jul 2017 10:41:48 GMT
Server: Apache
Content-Length: 226
Connection: Keep-Alive
Content-Type: text/html; charset=iso-8859-1

<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>400 Bad Request</title>
</head><body>
<h1>Bad Request</h1>
<p>Your browser sent a request that this server could not understand.<br />
</p>
</body></html>

 

4.io讀取http請求

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/


package main

import (
    "net"
    "log"
    "fmt"
    "reflect"
    "io"
    "os"
)

func main() {
    addr := "wwww.baidu.com:80" //定義主機名
    conn,err := net.Dial("tcp",addr) //撥號操作，需要指定協議。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("訪問公網IP地址以及端口是：",conn.RemoteAddr().String()) /*獲取“conn”中的公網地址。注意：最好是加上后面的String方法，因為他們的那些是不一樣的喲·當然你打印的時候
    可以不加輸出結果是一樣的，但是你的內心是不一樣的喲！*/
    fmt.Printf("客戶端鏈接的地址及端口是：%v\n",conn.LocalAddr()) //獲取到本地的訪問地址和端口。
    fmt.Println("“conn.LocalAddr()”所對應的數據類型是：",reflect.TypeOf(conn.LocalAddr()))
    fmt.Println("“conn.RemoteAddr().String()”所對應的數據類型是：",reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服務端發送數據。用n接受返回的數據大小，用err接受錯誤信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("寫入的大小是:",n)
    io.Copy(os.Stdout,conn)
    conn.Close()
}




#以上代碼輸出結果如下：
訪問公網IP地址以及端口是： 111.13.101.208:80
客戶端鏈接的地址及端口是：172.16.3.210:52409
“conn.LocalAddr()”所對應的數據類型是： *net.TCPAddr
“conn.RemoteAddr().String()”所對應的數據類型是： string
寫入的大小是: 18
HTTP/1.1 400 Bad Request
Date: Tue, 01 Aug 2017 02:35:11 GMT
Server: Apache
Content-Length: 226
Connection: Keep-Alive
Content-Type: text/html; charset=iso-8859-1

<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>400 Bad Request</title>
</head><body>
<h1>Bad Request</h1>
<p>Your browser sent a request that this server could not understand.<br />
</p>
</body></html>

 

三.服務端Socket；

1.串行服務端；

　　當客戶端鏈接過來的時候，我們服務端可以給客戶端回復特定的字符串等等。我們就以下面這段代碼為例子：

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "time"
)

func main() {
    addr := "0.0.0.0:8080" //表示監聽本地所有ip的8080端口，也可以這樣寫：addr := ":8080"
    listener,err := net.Listen("tcp",addr) //使用協議是tcp，監聽的地址是addr
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close() //關閉監聽的端口
    for  {
        conn,err := listener.Accept() //用conn接收鏈接
        if err != nil {
            log.Fatal(err)
        }
        conn.Write([]byte("Yinzhengjie\n"))  //通過conn的wirte方法將這些數據返回給客戶端。
        conn.Write([]byte("hello Golang\n"))
        time.Sleep(time.Minute) //在結束這個鏈接之前需要睡一分鍾在結束當前循環。
        conn.Close() //與客戶端斷開連接。
    }
}

　　注意，我們需要在服務端運行代碼，然后在客戶端進行telnet連接，如果操作的呢？很簡單，我用了2台網絡設備做測試：

路由器連接：

　　　　　　　　　　 　　　　  

防火牆連接：

　　　　　　　　　　　　　　　　　　　　

 

　　我用兩個網絡設備在1分鍾內同時連接服務器，發現先連接的路由器收到了回復，然后就一直在sleep，沒有下文了，這個時候防火牆也在連接，但是一直是在連接狀態，也未出現斷開的情況，等過了一分鍾之后，分別出現了以下現象：

路由器連接：

　　　　　　　　　　　　　　　

防火牆連接：

 　　　　　　　　　　　　　　　　　　　　  

　　小伙伴們或許發現了規律，當路由器斷開連接的時候，防火牆開始受到數據了，然后在過一分鍾后防火牆也斷開連接了。因為我的代碼中在執行寫的是睡眠一分鍾后就斷開連接。

一分鍾后防火牆連接：

　　　　　　　　　　　　　　　　

 

2.並發服務端；

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "time"
)

func Handle_conn(conn net.Conn) { //這個是在處理客戶端會阻塞的代碼。
    conn.Write([]byte("Yinzhengjie\n"))  //通過conn的wirte方法將這些數據返回給客戶端。
    conn.Write([]byte("尹正傑是一個好男孩！\n"))
    time.Sleep(time.Minute)
    conn.Close() //與客戶端斷開連接。
}

func main() {
    addr := "0.0.0.0:8080" //表示監聽本地所有ip的8080端口，也可以這樣寫：addr := ":8080"
    listener,err := net.Listen("tcp",addr)
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()

    for  {
        conn,err := listener.Accept() //用conn接收鏈接
        if err != nil {
            log.Fatal(err)
        }
        go Handle_conn(conn)  //開啟多個協程。
    }
}

 

　　同意，我還是用路由器和防火牆做測試，發現這次效果迥然不同。

路由器連接效果：

　　　　　　　　　　　　　　　　

防火牆連接效果：

　　　　　　　　　　　　　　　　　　　　　  

　　我們很明顯發現，當兩個網絡設備同事去連接服務器的時候，此次的輸出結果是不一致的，2個客戶端同事獲得了回應，這就是服務器的並發效果，可以在同一時間處理多個鏈接。等待一分鍾后，兩個客戶端都會自動斷開了鏈接。

路由器一分鍾后狀態：

　　　　　　　　　　　　　　　　  

防火牆一分鍾后狀態：

 　　　　　　　　　　　　　　　　　　　　　　

 3.web並發服務器；

　　其實我們寫的代碼也可以讓訪問對象是瀏覽器，這個時候我們返回其特定的html標簽標簽即可，代碼如下：

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
)


var content = `HTTP/1.1 200 OK
Date: Sat, 29 Jul 2017 06:18:23 GMT
Content-Type: text/html
Connection: Keep-Alive
Server: BWS/1.1
X-UA-Compatible: IE=Edge,chrome=1
BDPAGETYPE: 3
Set-Cookie: BDSVRTM=0; path=/

<html>
<head  name="尹正傑" age="25">  <!--標簽的開頭,其和面跟的內容（name="尹正傑"）是標簽的屬性,其屬性可以定義多個。-->
    <meta charset="UTF-8"/>     <!--指定頁面編碼，-->
    <meta http-equiv="refresh" content="30; Url=http://www.cnblogs.com/yinzhengjie/"> <!--這是做了一個界面的跳轉，表示30s不運行的話就跳轉到指定的URL-->
    <title>尹正傑的個人主頁</title> <!--定義頭部的標題-->
</head> <!--標簽的結尾-->

<body>
<h1 style="color:red">尹正傑</h1>
<h1 style="color:green">hello golang</h1>

</body>
</html>
`

func Handle_conn(conn net.Conn) { //這個是在處理客戶端會阻塞。
    conn.Write([]byte(content)) //將html的代碼返回給客戶端，這樣客戶端在web上訪問就可以拿到指定字符。
    conn.Close()
}


func main() {
    addr := "0.0.0.0:8080" //表示監聽本地所有ip的8080端口，也可以這樣寫：addr := ":8080"
    listener,err := net.Listen("tcp",addr)
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()

    for  {
        conn,err := listener.Accept() //用conn接收鏈接
        if err != nil {
            log.Fatal(err)
        }
        go Handle_conn(conn) //將接受來的鏈接交給該函數去處理。
    }
}

　　客戶端訪問效果如下：

　　　　　　　　

　　我們發現30s過后后頁面發生了變化如下：

　　　　　　　　　　　　

　　通過這個案例，可能大家會想我能不能把文件的內容傳給客戶端呢？當然是可以的啦~寫法也很簡單，就直接把讀內容轉換成“[]byte”類型然后返回給客戶端即可，在這里我就不多廢話了。

 

四.socket鏈接的應用；

1.寫個FTP服務器初級版本；

服務端：

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "io"
    "fmt"
    "bufio"
    "strings"
    "os"
    "path/filepath"
    "io/ioutil"
)

var  (
    cmd  string
    file_name string
)

func main() {
    addr := "0.0.0.0:8080" //表示監聽本地所有ip的8080端口，也可以這樣寫：addr := ":8080"
    listener,err := net.Listen("tcp",addr)
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()
    conn,err := listener.Accept() //用conn接收鏈接
    if err != nil {
        log.Fatal(err)
    }
    conn.Write([]byte("歡迎來到尹正傑迷你FTP服務器！"))
    r := bufio.NewReader(conn) //將這個鏈接（connection）包裝以下。將conn的內容都放入r中，但是沒有進行讀取，讓步我們一會對其進行操作。
    for  {
        line,err := r.ReadString('\n') //將r的內容也就是conn的數據按照換行符進行讀取。
        if err == io.EOF {
            conn.Close()
        }
        fmt.Print(line)
        line = strings.TrimSpace(line)  //去掉換行符。
        fmt.Println(len(strings.Fields(line)))
        if len(line) == 0 {  //為了讓客戶端長時間和服務器通話。
            continue
        }
        cmd = strings.Fields(line)[0]
        if len(strings.Fields(line)) > 1 {
            file_name = strings.Fields(line)[1]  //需要獲取服務器的文件
        }
        pwd,err := os.Getwd()
        if err != nil {
            panic("獲取路徑出錯了！")
        }
        file_name = filepath.Join(pwd,file_name)
        fmt.Println(file_name)
        switch  cmd{
        case  "GET","get":
            f,err := os.Open(file_name) //打開文件的內容。
            if err != nil {
                fmt.Println(err)
            }
            defer f.Close()
            buf,err := ioutil.ReadAll(f)
            if err != nil {
                log.Print(err)
                return
            }
            conn.Write(buf)
        case "PUSH","push":
            fmt.Println("上傳文件的語句")
            conn.Write([]byte("上傳文件的命令\n"))

        case "EXIT","exit":
            //conn.Close()
            return
        default:
            fmt.Println("您輸入的命令無效！")
            conn.Write([]byte("您輸入的指令有問題!\n"))
        }
    }
}

客戶端：

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

import (
    "net"
    "log"
    "fmt"
    "bufio"
    "os"
    "io"
)

var   (
    cmd string
    line string
)

func main() {
    addr := "172.16.3.210:8080" //定義主機名
    conn,err := net.Dial("tcp",addr) //撥號操作，用於連接服務端，需要指定協議。
    if err != nil {
        log.Fatal(err)
    }

    buf := make([]byte,10240) //定義一個切片的長度是10240。
    n,err := conn.Read(buf) //接收到的內容大小為我們提前定義好的大小。
    if err != nil && err != io.EOF {  //io.EOF在網絡編程中表示對端把鏈接關閉了。
        log.Fatal(err)
    }
    fmt.Println(string(buf[:n])) //將接受的內容都讀取出來。



    f := bufio.NewReader(os.Stdin)
    for  {
        //fmt.Print("請輸入>>>:")
        line,err = f.ReadString('\n') //定義一行的內容，結束標識符是換行符“\n”
        fmt.Sscan(line,&cmd)
        if len(line) == 1 {
            continue
        }
        //fmt.Print(line)
        go sender(conn,line)
    }
    conn.Close()  //斷開TCP鏈接。
}

func sender(conn net.Conn ,line string)  {
    n,err := conn.Write([]byte(line)) //向服務端發送數據。用n接受返回的數據大小，用err接受錯誤信息。
    if err != nil {
        log.Fatal(err)
    }

    buf := make([]byte,10) //定義一個切片的長度是1024。

    for  {
        n,err = conn.Read(buf) //接收到的內容大小。
        if err == io.EOF {
            conn.Close()
        }
        fmt.Print(string(buf[:n]))
    }
    return
}

測試結果：

歡迎來到尹正傑迷你FTP服務器！
get a.txt
11111
22222
33333

get \Day9\yinzhengjie.html
<!DOCTYPE html>       <!--Doctype告訴瀏覽器使用什么樣的html或xhtml規范來解析html文檔。html這種模式兼容瀏覽器是最好的-->
<html lang="en">
<head  name="尹正傑" age="25">  <!--標簽的開頭,其和面跟的內容（name="尹正傑"）是標簽的屬性,其屬性可以定義多個。-->
    <meta charset="UTF-8"/>     <!--指定頁面編碼，-->
    <meta http-equiv="refresh" content="30; Url=http://www.cnblogs.com/yinzhengjie/"> <!--這是做了一個界面的跳轉，表示3s不運行的話就跳轉到指定的URL-->
    <title>尹正傑的個人主頁</title> <!--定義頭部的標題-->
    <meta name="keywords" content="開發者,博客園,開發者,程序猿,程序媛,極客,編程,代碼,開源,IT網站,Developer,Programmer,Coder,Geek,技術社區" /> <!--“content”定義關鍵字，其作用就是讓瀏覽器通過搜索關鍵字時，會匹配該網站，這就是說如果你沒有單獨給百度錢的話，這些關鍵字就尤為重要啦！-->
    <meta name="description" content="博客園是一個面向開發者的知識分享社區。自創建以來，博客園一直致力並專注於為開發者打造一個純凈的技術交流社區，推動並幫助開發者通過互聯網分享知識，從而讓更多開發者從中受益。博客園的使命是幫助開發者用代碼改變世界。" />  <!--定義描述字符,其作用就告訴客戶你的這個網站是干嘛使用的。-->
    <link rel="shortcut icon" href="https://baike.baidu.com/pic/%E9%82%93%E7%B4%AB%E6%A3%8B/6798196/0/d1a20cf431adcbef011db9bba6af2edda3cc9f66?fr=lemma&ct=single#aid=0&pic=d1a20cf431adcbef011db9bba6af2edda3cc9f66" type="image/x-icon" /> <!--定義頭部圖標-->
    <meta http-equiv="x-ua-compatible" content="IE=Edge"> <!--這個是IE的瀏覽器生效的規則，如果你用的是谷歌，360等瀏覽器的話，這行規則不生效，如果你用的是IE瀏覽器的話，表示用IE最新的引擎去渲染HTML-->
</head> <!--標簽的結尾-->
<body>
<h1>尹正傑</h1><!--定義文件的內容，其中“h1”標簽中-->
<h2>尹正傑</h2>
<h3>尹正傑</h3>
<h4>尹正傑</h4>
<h5>尹正傑</h5>
<h6>尹正傑</h6>
<h1>You are a good boy!</h1>
<div style="width: 4000px">  <!--是其縮進代碼的腹肌標簽，給其定義寬度屬性是200像素大小-->
    <h1>尹正傑</h1><!--塊級標簽：也叫父�即自己單獨占了一行空�標簽，��說是占它父級標簽的100%。作�間，或蔨：定義文件的內容-->
    <h1>You are a good boy!</h1>
</div>  <!--div的標簽的結尾-->
<p>素胚勾勒出青花筆鋒濃轉淡<br/>瓶身描繪的牡丹一如你初妝<br/>冉冉檀香��事我�透過窗宣紙上贐然<br/>�筆至此擱一半<渲染仕�br/>釉色�被私藏<br/>而僉�圖韻呠嫣然的一笑如含苞待放</p> <!--其中<br/>表示換行符的意思，<p></p>表示一個段落的意思。-->
<a>yinzhengjie</a> <!--內聯標簽，以a開頭的標簽都是內聯標簽，�的內容�些標簽��連接在一起的a>2017</a>。:-->
<"http://ww
<a href=w.cnblogs.com/yinzhengjie/" target="_blank">尹正傑博客</a>  <!--a標簽特有的性能，重定向，通過href屬性定義需要跳轉的網站，通過target="_blank"表示新打開一個標簽頁並打開新的URL地址-->

<a href="#Y1">Golang第一!--a標簽特有的�章</a>  <�錨，找��能，�ID為"Y1"的標簽--="#Y2">Gol>
<a href��</a>  <!ang第二�"Y2"的標--找ID為簽-->
<a href="#Y3�三章</a">Golang�>  <!--找ID為"Y3"的標簽-->



<div id="Y1" style="height:700px;background-color:antiquewhite">  <!--用id來定義標簽為"Y1",用style來定義高度為700像素，顏色用background-color來定義-->
    Golang進階之路Day1<br/>
    Go語言官方自稱,之所以開發Go 語言,是因為“近10年來開發程序之難讓我們有點沮喪”。 這一定位暗示了Go語言希望取代C和Java的地位,成為最流行的通用開發語言。博客地址：http://www.cnblogs.com/yinzhengjie/p/6482675.html
</div>

<div id="Y2" style="height:700px;background-color:rebeccapurple;">
    <br/>Golang進階之路Day2<br/>
    前者大家應該都很熟悉，因為我在上一篇（http://www.cnblogs.com/yinzhengjie/p/6482675.html）關於GO的博客中用"go build"命令編譯不同的版本，但是在這里我們還是要演示一下go build的花式用法。博客地址：http://www.cnblogs.com/yinzhengjie/p/7000272.html
</div>

<div id="Y3" style="height:700px;background-color:brown;">
    Golang進階之路Day3<br/>
    當然我這里只是介紹��冰山�了Golang�角，對Golang感興趣的小伙伴，可以看一下Golang官網的文檔說明。畢竟官方才是最權�出國內地址：https://golang.org/pkg/!博客威的，�tp://www.c��址：htnblogs.com/yinzhengjie/p/7043430.html
</div>

<!--功能最少的標簽，最純潔的易於加工的標簽-->
<div>我是塊標簽</div>
<span>我是內聯標簽</span>

<!--列表-->
<ul>    <!--打印字符穿前面帶個小黑點-->
    一</li>
    <li>菜單二</li>
    <li>菜單三</li>
</ul>

<ol>  <!--打印字符串前面有數字標識-->
    <li>第�<li>菜單
    <li>第二章</li>
    <li>第三��章</li>章</li>
ol>
    <</ol>

<dd>北京<自帶縮進，可以用於寫新聞的�/dd>  <!--��題-->
    <dt>朝陽區</dt>亦庄�t>
    <d區</dt>
�濟開發    <dt>�t>
    <dt>海淀區</dt>
    <dd>河�台區</d��</dd>
 家庄</dt>
    <dt>保定</d   <dt>石d>陝西</dd>
    <dt>西安</dt>
    <dt>安康t>
    <dl>


<!--表格-->
<table border="1">   <!--�</dt>
</o表格，�義一個�border="1��屬性�"，表示加邊框�-->
    <thead>    <!--定義表頭信息-->
    <tr>   <��意思�!--'tr'表示定義一行的�面的內容由子栰據，里�簽<th></th>實現-  <th>姓名</th>    <!--'th'�->
      ��義同一行的內是說只�容,也就��帶有這個標簽的且在其父標簽"tr"標簽中就是寫的同�。-->
 ��行內�>年齡</t       <th  <td>性�h>
      ��</td>
    </tr>
    </thead>
    <tbody> <!--��的內容-->
    <tr>  <!--'tr'表示定義表暄數據�每一行�其定義的是行的操作。-->
        <td>尹正傑</tthead中的'th'用�d> <!--與�相同。只不過'th’有�！-->
        <td>�粗效果       <td25</td>
 
  <!--'tr'表示每�
    <tr>��行的數據-->
        <td>尹正傑</td> <!--‘<td></t�定義的d>’標�是列的操作-->
        <td colspan="2">26</td>     <!--表示這䭾占兩券�'td'標�的空間-->
    </tr>
    'tr'表示<tr>  <!--每一行的數據-->
        <td>yinzhengjie</td> <!--‘<td></td>’標簽定��的操�義的是�-->
d'標簽�
    </tr>
    <tr>  <!--'tr'表示每�據-->
        <td��行的�>yinzhengjie</td> <!--‘<td><簽定義的是列�/td>’標�操作-->
        <td >26</t-表示這個'td'標簽占兩列的空�d>     <!-�-->
    </tr>
    </tbody>
</table>
</body>
</html>

　　該腳本並沒有完成完整的FTP，只是寫了一個引子，放在這里，如果以后我有興趣了，可能會把它優化一下，我把這段代碼貼在這里就是為了提供一個網絡socket的傳輸案例，方便我以后查看，哈哈~

 

2.后台聊天程序；

　　該程序主要實現了，不同用戶登錄服務器可以輸入相同的密碼，然后大家可以互相通信的小程序。具體代碼和注釋如下：

/*
#!/usr/bin/env gorun
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/GO%E8%AF%AD%E8%A8%80%E7%9A%84%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/

package main

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

var globalRoom *Room = NewRoom()

type Room struct {
    users map[string]net.Conn
}

func NewRoom() *Room {
    return &Room{
        users: make(map[string]net.Conn),
    }
}

func (r *Room) Join(user string, conn net.Conn) {
    _, ok := r.users[user]
    if ok {
        r.Leave(user) //如果存在用戶user就提出之前的鏈接，調用Leave方法實現。
    }
    r.users[user] = conn
    fmt.Printf("%s 登錄成功。\n", user)
    conn.Write([]byte(user + ":加入聊天室!\n"))
}

func (r *Room) Leave(user string) {
    conn, ok := r.users[user]
    if !ok {
        fmt.Printf("%v用戶不存在！", user)
    }
    conn.Close() //如果存在用戶就斷開鏈接。
    delete(r.users, user) //將用戶從字典中刪除。
    fmt.Printf("%s 離開", user)
}

func (r *Room) Broadcast(who string, msg string) {
    time_info := time.Now().Format("2006年01月02日 15:04:05") //這個是對日期定義一個格式化輸出。告訴你一個記住它的方法：2006-01-02 15:04:05對應着2006 1(01) 2(02) 3(15) 4(04) 5(05) 哈哈
    tosend := fmt.Sprintf("%v %s:%s\n", time_info,who, msg)
    for user, conn := range r.users { //遍歷所有用戶，
        if user == who {
            continue //當發現用戶是自己就不發送數據。即跳過循環。
        }
        conn.Write([]byte(tosend)) //將數據發送給登陸的用戶。
    }
}

func Handle_Conn(conn net.Conn) {
    defer conn.Close()
    r := bufio.NewReader(conn) //將用戶的輸入存入“r”中，方便一會我們按塊讀取。
    line, err := r.ReadString('\n')
    if err != nil {
        fmt.Println(err)
        return
    }
    line = strings.TrimSpace(line)
    fields := strings.Fields(line)
    if len(fields) != 2 {
        conn.Write([]byte("您輸入的字符串用戶名活密碼無效，程序強制退出！\n"))
        return
    }
    user := fields[0]
    password := fields[1]
    if password != "123" {
        return
    }
    globalRoom.Join(user, conn)
    globalRoom.Broadcast("System", fmt.Sprintf("%s join room", user))
    for { //獲取用戶的輸入。
        conn.Write([]byte("按回車鍵發送消息：>>>"))//這里是給客戶端增加一個提示符
        line, err := r.ReadString('\n') //循環讀取用戶輸入的內容。換行符為“\n”
        if err != nil {                 //當用戶主動關閉連接是，會出現報錯就直接直接終止循環。
            break
        }
        line = strings.TrimSpace(line)   //去掉換行符
        fmt.Println(user,line)
        globalRoom.Broadcast(user, line) // 將用戶輸入的消息進行廣播。
    }
    globalRoom.Broadcast("System", fmt.Sprintf("%s Leave room", user))
    globalRoom.Leave(user) //踢掉用戶。
}

func main() {
    addr := "0.0.0.0:8888"
    listener, err := net.Listen("tcp", addr)
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()
    for {
        conn, err := listener.Accept()
        if err != nil {
            log.Fatal(err)
        }
        go Handle_Conn(conn)
    }
}