使Golang TCP服务器并发

发布时间：2020-12-16 09:27:59 所属栏目：大数据来源：网络整理

导读：Go的新手并试图使TCP服务器并发.我找到了这方面的多个例子,包括 this one,但我想弄清楚的是为什么我对非并发版本所做的一些改变不起作用. 这是我开始的原始示例代码 package mainimport "bufio"import "fmt"import "log"import "net"import "strings" // onl

Go的新手并试图使TCP服务器并发.我找到了这方面的多个例子,包括 this one,但我想弄清楚的是为什么我对非并发版本所做的一些改变不起作用.

这是我开始的原始示例代码

package main
import "bufio"
import "fmt"
import "log"
import "net"
import "strings" // only needed below for sample processing

func main() {
  fmt.Println("Launching server...")
  fmt.Println("Listen on port")
  ln,err := net.Listen("tcp","127.0.0.1:8081")
  if err != nil {
      log.Fatal(err)
  }
  defer ln.Close()

  fmt.Println("Accept connection on port")
  conn,err := ln.Accept()
  if err != nil {
      log.Fatal(err)
  }

  fmt.Println("Entering loop")
  // run loop forever (or until ctrl-c)
  for {
    // will listen for message to process ending in newline (n)
    message,_ := bufio.NewReader(conn).ReadString('n')
    // output message received
    fmt.Print("Message Received:",string(message))
    // sample process for string received
    newmessage := strings.ToUpper(message)
    // send new string back to client
    conn.Write([]byte(newmessage + "n"))
  }
}

以上工作,但它不是并发的.

这是我修改后的代码

package main
import "bufio"
import "fmt"
import "log"
import "net"
import "strings" // only needed below for sample processing

func handleConnection(conn net.Conn) {
  fmt.Println("Inside function")
  // run loop forever (or until ctrl-c)
  for {
    fmt.Println("Inside loop")
    // will listen for message to process ending in newline (n)
    message,string(message))
    // sample process for string received
    newmessage := strings.ToUpper(message)
    // send new string back to client
    conn.Write([]byte(newmessage + "n"))
  }

}

func main() {
  fmt.Println("Launching server...")
  fmt.Println("Listen on port")
  ln,"127.0.0.1:8081")
  if err != nil {
      log.Fatal(err)
  }
  //defer ln.Close()

  fmt.Println("Accept connection on port")
  conn,err := ln.Accept()
  if err != nil {
      log.Fatal(err)
  }
  fmt.Println("Calling handleConnection")
  go handleConnection(conn)

}

我将我的代码基于我发现的并发服务器的其他几个示例,但是当我运行上面的服务器似乎退出而不是运行handleConnection函数

Launching server…

Listen on port

Accept connection on port

Calling handleConnection

我会发现任何反馈作为类似的代码示例,我发现并使用相同的方法测试,同时调用函数来处理连接,工作;所以,想知道我看到的其他样本的修改代码有什么不同,因为它们对我来说似乎是一样的.

我不确定这是不是问题,但我试着评论延迟电话关闭.这没有用.

谢谢.

解决方法

您的主要功能是在接受新连接后立即返回,因此您的程序将在可以处理连接之前退出.由于您可能还希望接收多个单个连接(否则不会出现并发),因此应将其置于for循环中.

您还在for循环的每次迭代中创建一个新的缓冲读取器,这将丢弃任何缓冲的数据.你需要在for循环之外做这个,我在这里通过创建一个新的bufio.Scanner来演示,这是一种阅读换行分隔文本的简单方法.

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

func handleConnection(conn net.Conn) {
    defer conn.Close()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        message := scanner.Text()
        fmt.Println("Message Received:",message)
        newMessage := strings.ToUpper(message)
        conn.Write([]byte(newMessage + "n"))
    }

    if err := scanner.Err(); err != nil {
        fmt.Println("error:",err)
    }
}

func main() {
    ln,"127.0.0.1:8081")
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Accept connection on port")

    for {
        conn,err := ln.Accept()
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println("Calling handleConnection")
        go handleConnection(conn)
    }
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!