|
|
@ -1,6 +1,8 @@ |
|
|
|
package userrpc |
|
|
|
|
|
|
|
import ( |
|
|
|
"log" |
|
|
|
|
|
|
|
"git.tetele.net/tgo/conf" |
|
|
|
) |
|
|
|
|
|
|
@ -72,6 +74,8 @@ type FansReq struct { |
|
|
|
|
|
|
|
func rpc_server_conn(url ...string) (*UserServiceClient, error) { |
|
|
|
|
|
|
|
log.Println("userpc rpc_server_conn----", url) |
|
|
|
|
|
|
|
var rpc_url string |
|
|
|
if len(url) > 0 && url[0] != "" { |
|
|
|
rpc_url = url[0] |
|
|
@ -81,6 +85,8 @@ func rpc_server_conn(url ...string) (*UserServiceClient, error) { |
|
|
|
rpc_url = "127.0.0.1:" + conf.USER_RPC_PORT |
|
|
|
} |
|
|
|
|
|
|
|
log.Println("userpc rpc_url----", rpc_url) |
|
|
|
|
|
|
|
conn, _, err := DialUserService("tcp", rpc_url) |
|
|
|
if err != nil { |
|
|
|
return nil, err |
|
|
|