spider_util/src/gorunjs/client/client.go

package client

import (
	"context"
	"gorunjs/proto"
	"log"
	qu "qfw/util"
	"spiderutil"

	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"
)

var Client proto.GoRunJsClient

func InitGoRunJsClient() {
	defer qu.Catch()
	log.Println("address:", spiderutil.Config.JsServerAddress)
	conn, err := grpc.Dial(spiderutil.Config.JsServerAddress, grpc.WithTransportCredentials(insecure.NewCredentials()))
	if err != nil {
		log.Println("Init Connect Error: ", err)
	}
	Client = proto.NewGoRunJsClient(conn)
}

func GoRunJsGetResult(code, param, step string) (result string) {
	defer qu.Catch()
	req := &proto.GoRunJsReq{
		Code:  code,
		Param: param,
		Step:  step,
	}
	resp, err := Client.GoRunJsGetResult(context.Background(), req)
	if err != nil {
		qu.Debug("Go Run Js Get Result Error：", err)
	}
	return resp.Result
}

//func main() {
//	conn, err := grpc.Dial("127.0.0.1:8031", grpc.WithTransportCredentials(insecure.NewCredentials()))
//	if err != nil {
//		log.Fatalf("did not connect: %v", err)
//	}
//	defer conn.Close()
//	client := proto.NewGoRunJsClient(conn)
//	req := &proto.GoRunJsReq{
//		Code:  "a_zgmtkgjtdzcgpt_fzbgg",
//		Param: "486",
//		Step:  "list",
//	}
//	resp, err := client.GoRunJsGetResult(context.Background(), req)
//	if err != nil {
//		log.Fatalf("get code err: %v", err)
//	}
//	log.Println(resp.Result)
//}