Advertisement
Guest User

Untitled

a guest
Oct 26th, 2016
97
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Go 0.94 KB | None | 0 0
  1. package main
  2.  
  3. import (
  4.     "fmt"
  5.     "io"
  6.     "net"
  7. )
  8.  
  9. func main() {
  10.     listener, serverStartError := net.Listen("tcp", "127.0.0.1:1234")
  11.     if serverStartError != nil {
  12.         fmt.Println("Error starting the server: " + serverStartError.Error())
  13.     }
  14.  
  15.     defer listener.Close()
  16.  
  17.     for {
  18.         conn, listenerAcceptError := listener.Accept()
  19.         if listenerAcceptError != nil {
  20.             fmt.Println("Error accepting listener connection: " +
  21.                 listenerAcceptError.Error())
  22.         }
  23.         fmt.Println("New connection: " + conn.RemoteAddr().String())
  24.  
  25.         go handleConnection(conn)
  26.     }
  27.  
  28.     fmt.Scanln()
  29. }
  30.  
  31. func handleConnection(conn net.Conn) {
  32.     tmp := make([]byte, 1024)
  33.     buf := make([]byte, 0, 2)
  34.  
  35.     for {
  36.         n, err := conn.Read(tmp)
  37.         fmt.Println(n)
  38.         if err != nil {
  39.             fmt.Println("ERROR", err.Error())
  40.  
  41.             if err != io.EOF {
  42.                 fmt.Println("EOF ERROR")
  43.             }
  44.  
  45.             break
  46.         }
  47.         fmt.Println("APPENDING")
  48.         buf = append(buf, tmp[:n]...)
  49.     }
  50.  
  51.     fmt.Println(buf)
  52. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement