获取session信息服务（登陆相关）#

1
#Request:
2
method: GET
3
url:api/v1.0/session
4
data:no input data
5
#Response
6
#返回成功：
7
{
8
    "errno": "0",
9
    "errmsg":"OK",
10
    "data": {"name" : "13313331333"}
11

12
}
13
#注册失败：
14
{
15
    "errno": "400x",   //状态码
16
    "errmsg":"状态错误信息"
17
}

1
service Example {
2
  rpc GetSession(Request) returns (Response) {}
3
}
4

5
message Request {
6
    string Sessionid = 1;
7
}
8

9
message Response {
10
  string Errno = 1;
11
    string Errmsg = 2;
12
    string Data = 3;
13
}

1
//获取session
2
func GetSession(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
3
  beego.Info("获取Session url：api/v1.0/session")
4

5
  //创建服务
6
  service := grpc.NewService()
7
  service.Init()
8

9
  //创建句柄
10
  exampleClient := GETSESSION.NewExampleService("go.micro.srv.GetSession", service.Client())
11

12
  //获取cookie
13
  userlogin,err:=r.Cookie("userlogin")
14

15
  //如果不存在就返回
16
  if err != nil{
17

18
    //创建返回数据map
19
    response := map[string]interface{}{
20
      "errno": utils.RECODE_SESSIONERR,
21
      "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
22

23
    }
24

25
    w.Header().Set("Content-Type", "application/json")
26
    // encode and write the response as json
27
    if err := json.NewEncoder(w).Encode(response); err != nil {
28
      http.Error(w, err.Error(), 503)
29
      beego.Info(err)
30
      return
31
    }
32
    return
33
  }
34

35
  //存在就发送数据给服务
36
  rsp, err := exampleClient.GetSession(context.TODO(),&GETSESSION.Request{
37
    Sessionid:userlogin.Value,
38
  })
39

40
  if err != nil {
41
    http.Error(w, err.Error(), 502)
42

43
    beego.Info(err)
44
    //beego.Debug(err)
45
    return
46
  }
47

48

49
  // we want to augment the response
50
  //将获取到的用户名返回给前端
51
  data := make(map[string]string)
52
  data["name"]=rsp.Data
53
  response := map[string]interface{}{
54
    "errno": rsp.Errno,
55
    "errmsg": rsp.Errmsg,
56
    "data" : data,
57
  }
58

59
  w.Header().Set("Content-Type", "application/json")
60

61
  // 将返回数据map发送给前端
62
  if err := json.NewEncoder(w).Encode(response); err != nil {
63
    http.Error(w, err.Error(), 503)
64
    return
65
  }
66
}

1
func (e *Example) GetSession(ctx context.Context, req *example.Request, rsp *example.Response) error {
2
  beego.Info(" GET session    /api/v1.0/session !!!")
3
  //创建返回空间
4
  //初始化的是否返回不存在
5
  rsp.Errno = utils.RECODE_SESSIONERR
6
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
7

8
  ////获取前端的cookie
9
  beego.Info(req.Sessionid,reflect.TypeOf(req.Sessionid))
10
  //构建连接缓存的数据
11
  redis_config_map := map[string]string{
12
    "key":utils.G_server_name,
13
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
14
    "dbNum":utils.G_redis_dbnum,
15
  }
16
  beego.Info(redis_config_map)
17
  redis_config ,_:=json.Marshal(redis_config_map)
18
  beego.Info( string(redis_config) )
19

20
  //连接redis数据库 创建句柄
21
  bm, err := cache.NewCache("redis", string(redis_config) )
22
  if err != nil {
23
    beego.Info("缓存创建失败",err)
24
    rsp.Errno  =  utils.RECODE_DBERR
25
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
26
    return  nil
27
  }
28

29
  //拼接key
30
  sessionidname :=  req.Sessionid + "name"
31
  //从缓存中获取session 那么使用唯一识别码  通过key查询用户名
32
  areas_info_value:=bm.Get(sessionidname)
33
  //查看返回数据类型
34
  beego.Info(reflect.TypeOf(areas_info_value) ,areas_info_value )
35

36
  //通过redis方法进行转换
37
  name ,err :=redis.String(areas_info_value,nil)
38
  if err!=nil{
39
    rsp.Errno = utils.RECODE_DATAERR
40
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
41
  }
42
  //查看返回数据类型
43
  beego.Info(name,reflect.TypeOf(name))
44

45

46
   //获取到了session
47
  rsp.Errno = utils.RECODE_OK
48
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
49
  rsp.Data = name
50

51
  return nil
52

53
}