TCP 클라이언트가 작동하지 않습니다. golang

Question

golang으로 작성된 rest-ful 인터페이스가 있습니다. 각 끝점에서 인증을 수행해야합니다. 인증이 완료되면 다시 TCP 서버로 전달해야합니다. tcp 클라이언트를 만들었으며 채널에서 오는 모든 값을 tcp 서버에 보내야합니다. 채널은 http 요청 본문에서 채워집니다. 문제는 말괄량이 명령을 실행하면 클라이언트가 응답없이 멈추는 것입니다. 그래서 분명히 무엇이 잘못되었는지를 잘못 판단하고 있습니다. 누구든지 내 문제가 무엇인지에 대한 통찰력을 가지고 있습니까? c <- bodyString에서

package main 

      import (
       "bufio" 
       "encoding/json" 
       "flag" 
       "fmt" 
       "io/ioutil" 
       "log" 
       "net" 
       "net/http" 
       "net/http/httputil" 
       "net/url" 
       "os" 
       "strconv" 

       auth "github.com/abbot/go-http-auth" 
      ) 

      type Configuration struct { 
       Server  string 
       Port   int64 
       UserName  string 
       Pwd   string 
       Realm   string 
       ProxyPort  int64 
       Edeserver  string 

      } 

      var (
       Config *Configuration 
       logp = flag.Bool("log", false, "enable logging") 
      ) 

      func ReadConfiguration() { 
       file, _ := os.Open("Config.json") 
       decoder := json.NewDecoder(file) 
       Config = &Configuration{} 
       err := decoder.Decode(&Config) 
       if err != nil { 
        fmt.Println("error:", err) 
       } 

      } 

      func Secret(user, realm string) string { 
       if user == Config.UserName { 
        // password is "hello" 
        return Config.Pwd 
       } 
       return "" 
      } 

      func reverseProxyTows(w http.ResponseWriter, authenticatedRequest *auth.AuthenticatedRequest) { 
       req := &authenticatedRequest.Request 

       if *logp { 
        log.Println(" Authenticated Username ", authenticatedRequest.Username) 
        log.Println(" Authenticated URL ", req.URL.RequestURI()) 
       } 

       destinationURL := fmt.Sprintf("http://%s:%d", Config.Server, Config.Port) 
       u, err := url.Parse(destinationURL) 
       if err != nil { 
        log.Fatal(err) 
       } 

       if *logp { 
        log.Println("reverse_proxy", u) 
       } 

       reverseProxy := httputil.NewSingleHostReverseProxy(u) 

       reverseProxy.ServeHTTP(w, req) 
      } 

      func openConnectionTotcp(edechannel chan string) { 
       conn, _ := net.Dial("tcp", Config.Edeserver) 
       text := <-edechannel 
       fmt.Fprintf(conn, text+"\n") 
       message, _ := bufio.NewReader(conn).ReadString('\n') 
       fmt.Print("Message from server: " + message) 
      } 


      func main() { 
       ReadConfiguration() 
       flag.Parse() 
       c := make(chan string) 
       go openConnectionTotcp(c) 

       fmt.Printf("Started proxy to destination server %v:%d and is listening on %d ", Config.Server, Config.Port, Config.ProxyPort) 

       authenticator := auth.NewBasicAuthenticator(Config.Realm, Secret) 
       http.HandleFunc("/", authenticator.Wrap(reverseProxyTows)) 
       http.HandleFunc("/tyrion/1", authenticator.Wrap(func(w http.ResponseWriter, authenticatedRequest *auth.AuthenticatedRequest) { 
        req := &authenticatedRequest.Request 
        bodyBytes, err2 := ioutil.ReadAll(req.Body) 
        if err2 != nil { 
         log.Fatal(err2) 
        } 
        bodyString := string(bodyBytes) 
        c <- bodyString 
        fmt.Fprintf(w, "success") 
       })) 
       http.ListenAndServe(":"+strconv.FormatInt(Config.ProxyPort, 10), nil) 
      } 

Answer 1

귀하의 코드 실행 블록 아무것도 그 버퍼링 채널에서 읽는 것으로 보인다 없기 때문입니다. 이 행은 다른 루틴이 채널에서 읽을 때까지 실행을 일시 중지합니다.