| 12345678910111213141516171819202122232425262728293031 |
- package main
- import (
- "fmt"
- "net"
- "net/rpc"
- "rocommon/myta"
- "rocommon/service"
- )
- func main() {
- cli := service.NewNetRedisConnector([]string{"124.222.49.98:6379"}, "", 12, 0)
- service.SetRedis(cli)
- rank := new(myta.Rank)
- err := rpc.Register(rank)
- if err != nil {
- fmt.Println(err)
- }
- lis, er := net.Listen("tcp", ":8888")
- if er != nil {
- fmt.Println(er)
- }
- for {
- conn, err := lis.Accept()
- if err != nil {
- fmt.Println("conn error:", err)
- continue
- }
- go rpc.ServeConn(conn)
- }
- }
|