|
|
@@ -12,8 +12,7 @@ import (
|
|
|
"net/rpc"
|
|
|
)
|
|
|
|
|
|
-type Sms struct {
|
|
|
-}
|
|
|
+type Sms struct{}
|
|
|
|
|
|
var pool = make(chan bool, Config.PoolSize)
|
|
|
var service Service
|
|
|
@@ -33,8 +32,8 @@ func main() {
|
|
|
//logx.SetWriter(logrusx.NewLogrusWriter())
|
|
|
//logger.SetConsole(false)
|
|
|
//logger.SetRollingDaily("./logs", "sms.log")
|
|
|
- frpc := new(Sms)
|
|
|
- rpc.Register(frpc)
|
|
|
+ smsRpc := new(Sms)
|
|
|
+ rpc.Register(smsRpc)
|
|
|
rpc.HandleHTTP()
|
|
|
//处理链接
|
|
|
listen, err := net.Listen("tcp", ":"+Config.Port)
|
