无聊在家，写了个调用v2ray接口的demo，各位mjj可以参考

king51

1. package main
   
2. 
   
3. import (
   
4.         "context"
   
5.         "fmt"
   
6.         "github.com/labstack/gommon/log"
   
7.         "github.com/satori/go.uuid"
   
8.         "google.golang.org/grpc"
   
9.         // proxy管理服务
   
10.         proxymanService "v2ray.com/core/app/proxyman/command"
    
11.         // 统计服务
    
12.         statsService "v2ray.com/core/app/stats/command"
    
13.         "v2ray.com/core/common/protocol"
    
14.         "v2ray.com/core/common/serial"
    
15.         "v2ray.com/core/proxy/vmess"
    
16. )
    
17. 
    
18. // 添加用户
    
19. func addUser(conn *grpc.ClientConn) error {
    
20.         client := proxymanService.NewHandlerServiceClient(conn)
    
21.         userUUID := uuid.NewV4().String() //使用UUID库生成一个UUID
    
22.         resp, err := client.AlterInbound(context.Background(), &proxymanService.AlterInboundRequest{
    
23.                 Tag: "proxy", // 要添加用户的tag，目前只支持vmess协议
    
24.                 Operation: serial.ToTypedMessage(&proxymanService.AddUserOperation{
    
25.                         User: &protocol.User{
    
26.                                 Level: 0,                 // 用户等级
    
27.                                 Email: "usermail@qq.com", // 用户邮箱，删除和统计要用到
    
28.                                 Account: serial.ToTypedMessage(&vmess.Account{
    
29.                                         Id:               userUUID,                                                   //用户UUID
    
30.                                         AlterId:          4,                                                          // 额外ID
    
31.                                         SecuritySettings: &protocol.SecurityConfig{Type: protocol.SecurityType_AUTO}, // 安全设置，auto为自动判断加密协议
    
32.                                 }),
    
33.                         },
    
34.                 }),
    
35.         })
    
36.         if err != nil {
    
37.                 return err
    
38.         }
    
39.         fmt.Println(resp)
    
40.         fmt.Println(userUUID)
    
41.         return nil
    
42. }
    
43. 
    
44. // 删除用户
    
45. func removeUser(conn *grpc.ClientConn) error {
    
46.         client := proxymanService.NewHandlerServiceClient(conn)
    
47.         resp, err := client.AlterInbound(context.Background(), &proxymanService.AlterInboundRequest{
    
48.                 Tag: "proxy",
    
49.                 Operation: serial.ToTypedMessage(&proxymanService.RemoveUserOperation{
    
50.                         Email: "usermail@qq.com", // 用户邮箱地址
    
51.                 }),
    
52.         })
    
53.         if err != nil {
    
54.                 return err
    
55.         }
    
56.         fmt.Println(resp)
    
57.         return nil
    
58. }
    
59. 
    
60. // 获取用户流量
    
61. func queryUserTraffic(conn *grpc.ClientConn) error {
    
62.         client := statsService.NewStatsServiceClient(conn)
    
63.         resp, err := client.QueryStats(context.Background(), &statsService.QueryStatsRequest{
    
64.                 /*
    
65.                         user>>>[email]>>>traffic>>>uplink
    
66.                         特定用户的上行流量，单位字节。
    
67.                         user>>>[email]>>>traffic>>>downlink
    
68.                         特定用户的下行流量，单位字节。
    
69.                         inbound>>>[tag]>>>traffic>>>uplink
    
70.                         特定入站代理的上行流量，单位字节。
    
71.                         inbound>>>[tag]>>>traffic>>>downlink
    
72.                         特定入站代理的下行流量，单位字节。
    
73.                 */
    
74.                 Pattern: "user", // 筛选用户表达式
    
75.                 Reset_:  false,  // 查询完成后是否重置流量
    
76.         })
    
77.         if err != nil {
    
78.                 return err
    
79.         }
    
80.         // 获取返回值中的流量信息
    
81.         stat := resp.GetStat()
    
82.         // 返回的是一个数组，对其进行遍历输出
    
83.         for _, e := range stat {
    
84.                 fmt.Println(e)
    
85.         }
    
86.         return nil
    
87. }
    
88. 
    
89. func main() {
    
90.         // 连接grpc服务
    
91.         conn, err := grpc.Dial("IP:port", grpc.WithInsecure())
    
92.         if err != nil {
    
93.                 panic(err)
    
94.         }
    
95.         //err = queryUserTraffic(conn)
    
96.         err = addUser(conn)
    
97.         //err = removeUser(conn)
    
98.         if err != nil {
    
99.                 log.Info(err)
    
100.         }
     
101.         if err = conn.Close(); err != nil {
     
102.                 log.Info("关闭连接失败")
     
103.         }
     
104. }
     

复制代码

  初学go，感觉这语言挺好用啊

hasamol7468

可惜不是拍黄皮

king51

hasamol7468 发表于 2020-2-26 15:50
可惜不是拍黄皮

php毕竟不是谷歌自家 调用grpc麻烦

wuxjian

go error写的很恶心,我也写过一些

hasamol7468

king51 发表于 2020-2-26 15:53
php毕竟不是谷歌自家 调用grpc麻烦

的确，之前整过，很头大只好整了个中间件

风铃

king51 发表于 2020-2-26 15:53
php毕竟不是谷歌自家 调用grpc麻烦

也不是很麻烦 有grpc一键生成各种语言的, 转成php和js一样用
目前我用的js调用的

XiFanU

大佬大佬！话说 v.2.r.a.y api 的文档在哪里查看啊？

king51

XiFanU 发表于 2020-2-27 12:18
大佬大佬！话说 v.2.r.a.y api 的文档在哪里查看啊？

没有文档，自己参考谷歌上教程和demo做就行

Ruclinux

go 不会用