socket.go

package socket

import (
	"bufio"
	"fmt"
	"github.com/romana/rlog"
	"log"
	"net"
	"os"
	"strings"
)

func Listen(address string, port int) bool {

	listen, err := net.Listen("tcp4", fmt.Sprintf("%v:%d", address, port))
	defer listen.Close()

	if err != nil {

		rlog.Errorf("%v\n", err.Error())
		os.Exit(1)

		return false
	}

	rlog.Infof("Listening on IP: %s - Port: %v", address, port)

	for {

		conn, err := listen.Accept()

		if err != nil {
			log.Fatalln(err)
			continue
		}

		go handler(conn)
	}

	return true

}

func handler(conn net.Conn) {

	defer conn.Close()

	var (
		r = bufio.NewReader(conn)
	)

	for {

		buf, isPrefix, err := r.ReadLine()

		if !isPrefix {
			data := string(buf)

			if err != nil {
				rlog.Errorf("Receive data failed:%s", err)
				return
      }

			rlog.Infof("%v", data)
    } else {
      // something here?
    }

	}

}