|
|
@ -10,10 +10,11 @@ import (
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
"encoding/json"
|
|
|
|
"encoding/json"
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"github.com/gorilla/websocket"
|
|
|
|
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
|
|
|
|
"net"
|
|
|
|
"net"
|
|
|
|
"strings"
|
|
|
|
"strings"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"github.com/gorilla/websocket"
|
|
|
|
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
type RPCServer struct {
|
|
|
|
type RPCServer struct {
|
|
|
@ -41,7 +42,7 @@ func (r *RPCServer) run() {
|
|
|
|
srv := grpc.NewServer()
|
|
|
|
srv := grpc.NewServer()
|
|
|
|
defer srv.GracefulStop()
|
|
|
|
defer srv.GracefulStop()
|
|
|
|
pbRelay.RegisterOnlineMessageRelayServiceServer(srv, r)
|
|
|
|
pbRelay.RegisterOnlineMessageRelayServiceServer(srv, r)
|
|
|
|
err = getcdv3.RegisterEtcd4Unique(r.etcdSchema, strings.Join(r.etcdAddr, ","), ip, r.rpcPort, r.rpcRegisterName, 10)
|
|
|
|
err = getcdv3.RegisterEtcd(r.etcdSchema, strings.Join(r.etcdAddr, ","), ip, r.rpcPort, r.rpcRegisterName, 10)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
log.ErrorByKv("register push message rpc to etcd err", "", "err", err.Error())
|
|
|
|
log.ErrorByKv("register push message rpc to etcd err", "", "err", err.Error())
|
|
|
|
}
|
|
|
|
}
|
|
|
|