完善

demo/client/main.go

@@ -14,7 +14,10 @@ import (
 
 //服务地址配置
 var (
-	rdserver = flag.String("rd", "127.0.0.1:10021", "服务治理地址")
+	rdserver    = flag.String("rd", "127.0.0.1:10021", "服务治理地址")
+	balancetype = flag.Int("balance", 0, "负载策略 0=随机 1=服务器压力均衡 2=轮训占用")
+	threads     = flag.Int("threads", 20, "压力并发数")
+	requests    = flag.Int("reqs", 100, "单个线程服务请求次数")
 )
 
 func init() {
@@ -35,8 +38,8 @@ func run(thread int, wg *sync.WaitGroup) {
 	var client proto.ServiceClient
 	client = proto.NewServiceClient(conn)
 
-	for i := 0; i < 20; i++ {
-		repl, err := client.Apply(context.Background(), &proto.ApplyReqData{Name: "demo", Balance: 2})
+	for i := 0; i < *requests; i++ {
+		repl, err := client.Apply(context.Background(), &proto.ApplyReqData{Name: "demo", Balance: int32(*balancetype)})
 		if err != nil {
 			log.Println("出错了")
 			log.Fatalln(err.Error())
@@ -71,7 +74,7 @@ func run(thread int, wg *sync.WaitGroup) {
 
 func main() {
 	wg := new(sync.WaitGroup)
-	for i := 0; i < 3; i++ {
+	for i := 0; i < *threads; i++ {
 		wg.Add(1)
 		go run(i, wg)
 	}

disk/README.md

@@ -1,2 +1,11 @@
+# 说明
 输出的linux文件，
 可以直接使用。
+# 文件清单
+ - server   服务治理服务端
+ - agent 服务提供者服务器性能监控客户端
+ - service demo 服务提供者
+ - client demo 服务消费者
+
+# 使用方法：
+可以自行使用 --help查看说明