zoukankan      html  css  js  c++  java
  • [日常] Go语言*--Channel习题

    练习 8.3: 在netcat3例子中,conn虽然是一个interface类型的值,但是其底层真实类型是*net.TCPConn,代表一个TCP连接。一个TCP连接有读和写两个部分,可以使用CloseRead和CloseWrite方法分别关闭它们。修改netcat3的主goroutine代码,只关闭网络连接中写的部分,这样的话后台goroutine可以在标准输入被关闭后继续打印从reverb1服务器传回的数据。(要在reverb2服务器也完成同样的功能是比较困难的;参考练习 8.4。)


    1.
    net.Dial()
    func Dial(network, address string) (Conn, error)
    2.net.TCPConn
    type TCPConn struct {
    // contains filtered or unexported fields
    }
    TCPConn is an implementation of the Conn interface for TCP network connections.

    package main
    
    import (
            "io"
            "log"
            "net"
            "os"
    )
    
    func main() {
            conn, err := net.Dial("tcp", "localhost:8040")
            if err != nil {
                    log.Fatal(err)
            }   
            //内置make函数创建一个channel,可以发送struct类型的数据
            done := make(chan struct{})
            //go语句调用一个函数字面量,启动goroutine的常用形式
            go func() {
                    //从网络连接到标准输出,如果连接没断也会阻塞
                    //如果TCP的读连接关闭会报错:use of closed network connection
                    _, err := io.Copy(os.Stdout, conn)
                    log.Println(err)
                    log.Println("done")
                    //发送channel给接收goroutine
                    done <- struct{}{}
            }() 
            //从标准输入到网络连接中,这个地方会阻塞,按Control+D关闭标准输入
            mustCopy(conn, os.Stdin)
            //      conn.Close()
            //类型断言,调用*net.TCPConn的方法CloseWrite()只关闭TCP的写连接
            cw := conn.(*net.TCPConn)
            cw.CloseWrite()
            <-done // 阻塞等待后台 goroutine 完成接收channel
    }
    func mustCopy(dst io.Writer, src io.Reader) {
            if _, err := io.Copy(dst, src); err != nil {
                    log.Fatal(err)
            }   
    }
    

      

  • 相关阅读:
    SDN大作业
    第06组 Beta版本演示
    SqlServer 将多行字段合并成单行
    C# MD5加密字符串
    Request.IsAjaxRequest()总是返回false
    Mybatis 语句包含单引号的写法
    idea每次启动maven项目都貌似读不到配置
    idea下springboot项目配置文件application.properties不生效的问题
    Ubuntu 设置时区
    SpringBoot 使用MyBatis
  • 原文地址:https://www.cnblogs.com/taoshihan/p/8970647.html
Copyright © 2011-2022 走看看