Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import(
- "log"
- "net"
- "time"
- "fmt"
- )
- var rc net.Conn
- func main() {
- tcpListener()
- }
- func tcpListener(){
- ln, err := net.Listen("tcp", "localhost:9000")
- if err != nil{
- check(err)
- }
- for{
- c, err := ln.Accept()
- check(err)
- go handleConnection(c)
- }
- }
- func handleConnection(c net.Conn){
- fmt.Printf("\nheard\n")
- buf := make([]byte, 1024)
- n, _ := c.Read(buf)
- got := string(buf[:n])
- log.Print("\n"+got)
- time.Sleep(2 * time.Second)
- println("Dialing")
- rc, _ = net.Dial("tcp", c.RemoteAddr().String())
- time.Sleep(2 * time.Second)
- println("sending msg")
- rc.Write([]byte("msg"))
- time.Sleep(2 * time.Second)
- println("sending 2nd msg")
- //rc, _ = net.Dial("tcp", c.RemoteAddr().String())
- rc.Write([]byte("msg 2"))
- time.Sleep(2 * time.Second)
- println("sending 3rd msg")
- //rc, _ = net.Dial("tcp", c.RemoteAddr().String())
- rc.Write([]byte("msg 3"))
- }
- func check(err error) {
- if err != nil {
- println("SERVER Fatal error: ", err.Error())
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement