feat:更新

rpc/common/common.go

@@ -19,7 +19,7 @@ import (
 
 //
 func main() {
-	//热重启
+	//
 	go func() {
 		err := endless.ListenAndServe(":"+mc.InterfaceToStr(IC.C.Webrpcport), nil, func() {})
 		if err != nil {

rpc/consumer/consumer.go

@@ -1,13 +1,14 @@
 package main
 
 import (
+	"fmt"
+	"log"
+
 	IC "app.yhyue.com/moapp/jyInfo/rpc/consumer/init"
 	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/server"
 	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"
 	"app.yhyue.com/moapp/jyInfo/rpc/consumer/type/consumer"
 	"app.yhyue.com/moapp/jyInfo/rpc/util"
-	"fmt"
-	"log"
 
 	mc "app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/endless"
@@ -18,7 +19,7 @@ import (
 )
 
 func main() {
-	//热重启
+	//
 	go func() {
 		err := endless.ListenAndServe(":"+mc.InterfaceToStr(IC.C.Webrpcport), nil, func() {})
 		if err != nil {

rpc/manager/manager.go

@@ -1,8 +1,8 @@
 package main
 
 import (
-	"fmt"
 	"app.yhyue.com/moapp/jyInfo/rpc/util"
+	"fmt"
 	"log"
 
 	mc "app.yhyue.com/moapp/jybase/common"
@@ -22,7 +22,7 @@ import (
 )
 
 func main() {
-	//热重启
+	//
 	go func() {
 		err := endless.ListenAndServe(":"+mc.InterfaceToStr(IC.C.Webrpcport), nil, func() {})
 		if err != nil {

rpc/model/oss/oss.go

@@ -31,12 +31,13 @@ func OssPutObject(objectName string, fd io.Reader, ossBucketName string) (bool,
 		fmt.Println("Error:", err)
 		return false, err
 	}
-	// 上传文件流。
-	err = bucket.PutObject(objectName, fd)
-	if err != nil {
-		fmt.Println("Error:", err)
-		return false, err
-	}
+	// 上传文件流。 文件超过1M 上传时间超时
+	go func(objectName string, fd io.Reader) {
+		err = bucket.PutObject(objectName, fd)
+		if err != nil {
+			fmt.Println("file upload false:", err)
+		}
+	}(objectName, fd)
 
 	return true, nil
 }