删除（退出）登陆信息服务（登陆相关）#

1
#Request:
2
method: DELETE
3
url:api/v1.0/session
4
#data:
5
no input data
6
#Response
7
#返回成功：
8
{
9
    "errno": "0",
10
    "errmsg":"OK",
11
}
12
#返回失败：
13
{
14
    "errno": "400x",   //状态码
15
    "errmsg":"状态错误信息"
16
}

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

5

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

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

1
//退出登陆
2
rou.DELETE("/api/v1.0/session", handler.DeleteSession)

1
func DeleteSession(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
2
  beego.Info("---------------- DELETE  /api/v1.0/session Deletesession() ------------------")
3
  //创建返回空间
4

5
  server :=grpc.NewService()
6
  server.Init()
7
  exampleClient := DELETESESSION.NewExampleService("go.micro.srv.DeleteSession", server.Client())
8

9
  //获取session
10
  userlogin,err:=r.Cookie("userlogin")
11
  //如果没有数据说明没有的登陆直接返回错误
12
  if err != nil{
13
    resp := map[string]interface{}{
14
      "errno": utils.RECODE_SESSIONERR,
15
      "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
16
    }
17

18
    w.Header().Set("Content-Type", "application/json")
19
    // encode and write the response as json
20
    if err := json.NewEncoder(w).Encode(resp); err != nil {
21
      http.Error(w, err.Error(), 503)
22
      beego.Info(err)
23
      return
24
    }
25
    return
26
  }
27

28
  rsp, err := exampleClient.DeleteSession(context.TODO(),&DELETESESSION.Request{
29
    Sessionid:userlogin.Value,
30
  })
31

32
  if err != nil {
33
    http.Error(w, err.Error(), 502)
34

35
    beego.Info(err)
36
    //beego.Debug(err)
37
    return
38
  }
39
  //再次读取数据
40
  cookie,err :=r.Cookie("userlogin")
41

42
  //数据不为空则将数据设置副的
43
  if err !=nil || ""==cookie.Value{
44
    return
45
  }else {
46
    cookie := http.Cookie{Name: "userlogin", Path: "/", MaxAge: -1}
47
    http.SetCookie(w, &cookie)
48
  }
49

50

51
  //返回数据
52
  resp := map[string]interface{}{
53
    "errno": rsp.Errno,
54
    "errmsg": rsp.Errmsg,
55
  }
56
  //设置格式
57
  w.Header().Set("Content-Type", "application/json")
58

59
  // encode and write the response as json
60
  if err := json.NewEncoder(w).Encode(resp); err != nil {
61
    http.Error(w, err.Error(), 503)
62
    beego.Info(err)
63
    return
64
  }
65

66

67
  return
68
}

1
func (e *Example) DeleteSession(ctx context.Context, req *example.Request, rsp *example.Response) error {
2
  beego.Info(" DELETE session    /api/v1.0/session !!!")
3

4
  //创建返回空间
5
  //初始化的是否返回不存在
6
  rsp.Errno = utils.RECODE_OK
7
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
8

9
  ////获取前端的cookie
10
  beego.Info(req.Sessionid,reflect.TypeOf(req.Sessionid))
11

12

13
  //构建连接缓存的数据
14
  redis_config_map := map[string]string{
15
    "key":utils.G_server_name,
16
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
17
    "dbNum":utils.G_redis_dbnum,
18
  }
19
  beego.Info(redis_config_map)
20
  redis_config ,_:=json.Marshal(redis_config_map)
21

22
  //连接redis数据库 创建句柄
23
  bm, err := cache.NewCache("redis", string(redis_config) )
24
  if err != nil {
25
    beego.Info("缓存创建失败",err)
26
    rsp.Errno  =  utils.RECODE_DBERR
27
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
28
    return  nil
29
  }
30
  sessionidname :=  req.Sessionid + "name"
31
  sessioniduserid :=  req.Sessionid + "user_id"
32
  sessionidmobile :=  req.Sessionid + "mobile"
33

34
  //从缓存中获取session 那么使用唯一识别码
35
  bm.Delete(sessionidname)
36
  bm.Delete(sessioniduserid)
37
  bm.Delete(sessionidmobile)
38

39
  return nil
40
}