main.go 505 B

12345678910111213141516171819202122232425262728293031
  1. package main
  2. import (
  3. "fmt"
  4. "net"
  5. "net/rpc"
  6. "rocommon/myta"
  7. "rocommon/service"
  8. )
  9. func main() {
  10. cli := service.NewNetRedisConnector([]string{"124.222.49.98:6379"}, "", 12, 0)
  11. service.SetRedis(cli)
  12. rank := new(myta.Rank)
  13. err := rpc.Register(rank)
  14. if err != nil {
  15. fmt.Println(err)
  16. }
  17. lis, er := net.Listen("tcp", ":8888")
  18. if er != nil {
  19. fmt.Println(er)
  20. }
  21. for {
  22. conn, err := lis.Accept()
  23. if err != nil {
  24. fmt.Println("conn error:", err)
  25. continue
  26. }
  27. go rpc.ServeConn(conn)
  28. }
  29. }