10 上传用户头像#

1
#Request:
2
method: POST
3
url:api/v1.0/user/avatar
4
#data:
5
图片的二进制数据
6
#Response
7
#返回成功：
8
{
9
  "errno": "0",
10
  "errmsg": "成功",
11
  "data": {
12
    "avatar_url": "http://101.200.170.171:9998/group1/M00/00/00/Zciqq1n6_L-AOB04AADexS5wJKs662.png" //图片地址需要进行拼接
13
  }
14

15
}
16
#返回失败：
17
{
18
    "errno": "400x",   //状态码
19
    "errmsg":"状态错误信息"
20
}

1
package models
2

3
import (
4
  "github.com/weilaihui/fdfs_client"
5
  "github.com/astaxie/beego"
6
)
7

8
//通过文件名的方式进行上传
9
func UploadByFilename( filename string)(GroupName,RemoteFileId string ,err error ) {
10
  //通过配置文件创建fdfs操作句柄
11
  fdfsClient, thiserr :=fdfs_client.NewFdfsClient("/home/itcast/go/src/go-1/homeweb/conf/client.conf")
12
  if thiserr  !=nil{
13
    //说一下那里出问题了
14
    beego.Info("UploadByFilename( ) fdfs_client.NewFdfsClient  err",err)
15
    GroupName = ""
16
    RemoteFileId = ""
17
    err = thiserr
18
    return
19
  }
20

21
  //unc (this *FdfsClient) UploadByFilename(filename string) (*UploadFileResponse, error)
22
  //通过句柄上传文件（被上传的文件）
23

24
  uploadResponse, thiserr := fdfsClient.UploadByFilename(filename)
25
  if thiserr !=nil{
26
    beego.Info("UploadByFilename( ) fdfsClient.UploadByFilename(filename)  err",err)
27
    GroupName = ""
28
    RemoteFileId = ""
29
    err = thiserr
30
    return
31
  }
32

33
  beego.Info(uploadResponse.GroupName)
34
  beego.Info(uploadResponse.RemoteFileId)
35
  //回传
36
  return  uploadResponse.GroupName , uploadResponse.RemoteFileId ,nil
37

38
}
39

40

41

42

43
//功能函数 操作fdfs上传二进制文件
44
func UploadByBuffer(filebuffer []byte, fileExtName string)(GroupName,RemoteFileId string ,err error ){
45

46
  //通过配置文件创建fdfs操作句柄
47
  fdfsClient, thiserr :=fdfs_client.NewFdfsClient("/home/itcast/go/src/go-1/homeweb/conf/client.conf")
48
  if thiserr  !=nil{
49
    beego.Info("UploadByBuffer( ) fdfs_client.NewFdfsClient  err",err)
50
    GroupName = ""
51
    RemoteFileId = ""
52
    err = thiserr
53
    return
54
  }
55

56
  //通过句柄上传二进制的文件
57
  uploadResponse, thiserr :=fdfsClient.UploadByBuffer(filebuffer,fileExtName)
58
  if thiserr  !=nil{
59
    beego.Info("UploadByBuffer( ) fdfs_client.UploadByBuffer  err",err)
60
    GroupName = ""
61
    RemoteFileId = ""
62
    err = thiserr
63
    return
64
  }
65
  beego.Info(uploadResponse.GroupName)
66
  beego.Info(uploadResponse.RemoteFileId)
67
  //回传入
68
  return uploadResponse.GroupName,uploadResponse.RemoteFileId,nil
69

70
}

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

5
message Message {
6
  string say = 1;
7
}
8

9
message Request {
10
    //二进制图片
11
  bytes Avatar =1;
12
  //sessionid
13
    string Sessionid=2;
14
    //文件大小
15
    int64 filesize =3;
16
    //文件名字
17
    string filename =4 ;
18
}
19

20
message Response {
21
  //错误码
22
  string Errno = 1;
23
  //错误信息
24
    string Errmsg = 2;
25
    //回传的url
26
    string Avatar_url = 3;
27
}

1
//上传头像 POST
2
rou.POST("/api/v1.0/user/avatar",handler.PostAvatar)

1
//上传用户头像 PostAvatar
2
func PostAvatar(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
3
  beego.Info("上传用户头像 PostAvatar /api/v1.0/user/avatar")
4

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

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

12
  //查看登陆信息
13
  userlogin,err:=r.Cookie("userlogin")
14

15
  //如果没有登陆就返回错误
16
  if err != nil{
17
    resp := map[string]interface{}{
18
      "errno": utils.RECODE_SESSIONERR,
19
      "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
20
    }
21

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

32
  //接收前端发送过来的文集
33
  file,hander,err:=r.FormFile("avatar")
34

35
  //判断是否接受成功
36
  if err != nil{
37
    beego.Info("Postupavatar   c.GetFile(avatar) err" ,err)
38

39
    resp := map[string]interface{}{
40
      "errno": utils.RECODE_IOERR,
41
      "errmsg": utils.RecodeText(utils.RECODE_IOERR),
42
    }
43
    w.Header().Set("Content-Type", "application/json")
44
    // encode and write the response as json
45
    if err := json.NewEncoder(w).Encode(resp); err != nil {
46
      http.Error(w, err.Error(), 503)
47
      beego.Info(err)
48
      return
49
    }
50
    return
51
  }
52
  //打印基本信息
53
  beego.Info(file ,hander)
54
  beego.Info("文件大小",hander.Size)
55
  beego.Info("文件名",hander.Filename)
56

57
  //二进制的空间用来存储文件
58
  filebuffer:= make([]byte,hander.Size)
59

60
  //将文件读取到filebuffer里
61
  _,err = file.Read(filebuffer)
62
  if err !=nil{
63
    beego.Info("Postupavatar   file.Read(filebuffer) err" ,err)
64
    resp := map[string]interface{}{
65
      "errno": utils.RECODE_IOERR,
66
      "errmsg": utils.RecodeText(utils.RECODE_IOERR),
67
    }
68
    w.Header().Set("Content-Type", "application/json")
69
    // encode and write the response as json
70
    if err := json.NewEncoder(w).Encode(resp); err != nil {
71
      http.Error(w, err.Error(), 503)
72
      beego.Info(err)
73
      return
74
    }
75
    return
76
  }
77
  //调用函数传入数据
78
  rsp, err := exampleClient.PostAvatar(context.TODO(),&POSTAVATAR.Request{
79
    Sessionid:userlogin.Value,
80
    Filename:hander.Filename,
81
    Filesize:hander.Size,
82
    Avatar:filebuffer,
83
  })
84
  if err != nil {
85
    http.Error(w, err.Error(), 502)
86

87
    beego.Info(err)
88
    //beego.Debug(err)
89
    return
90
  }
91
  //
92

93
  //准备回传数据空间
94
  data := make(map[string]interface{})
95
  //url拼接然回回传数据
96
  data["avatar_url"]=utils.AddDomain2Url(rsp.AvatarUrl)
97

98

99

100
  resp := map[string]interface{}{
101
    "errno": rsp.Errno,
102
    "errmsg": rsp.Errmsg,
103
    "data":data,
104
  }
105

106
  w.Header().Set("Content-Type", "application/json")
107

108
  // encode and write the response as json
109
  if err := json.NewEncoder(w).Encode(resp); err != nil {
110
    http.Error(w, err.Error(), 503)
111
    beego.Info(err)
112
    return
113
  }
114

115

116
  return
117
}

1
// Call is a single request handler called via client.Call or the generated client code
2
func (e *Example) PostAvatar(ctx context.Context, req *example.Request, rsp *example.Response) error {
3
  beego.Info("上传用户头像 PostAvatar /api/v1.0/user/avatar")
4
  //初始化返回正确的返回值
5
  rsp.Errno = utils.RECODE_OK
6
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
7

8
  //检查下数据是否正常
9
  beego.Info(len(req.Avatar),req.Filesize)
10

11

12
  /*获取文件的后缀名*/     //dsnlkjfajadskfksda.sadsdasd.sdasd.jpg
13
  beego.Info("后缀名",path.Ext(req.Filename))
14

15
  /*存储文件到fastdfs当中并且获取 url*/
16
  //.jpg
17
  fileext :=path.Ext(req.Filename)
18
  //group1 group1/M00/00/00/wKgLg1t08pmANXH1AAaInSze-cQ589.jpg
19
  //上传数据
20
  Group,FileId ,err :=  models.UploadByBuffer(req.Avatar,fileext[1:])
21
  if err != nil {
22
    beego.Info("Postupavatar  models.UploadByBuffer err" ,err)
23
    rsp.Errno = utils.RECODE_IOERR
24
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
25
    return nil
26
  }
27
  beego.Info(Group)
28

29
  /*通过session 获取我们当前现在用户的uesr_id*/
30
  redis_config_map := map[string]string{
31
    "key":utils.G_server_name,
32
    //"conn":"127.0.0.1:6379",
33
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
34
    "dbNum":utils.G_redis_dbnum,
35
  }
36
  beego.Info(redis_config_map)
37
  redis_config ,_:=json.Marshal(redis_config_map)
38
  beego.Info( string(redis_config) )
39
  //连接redis数据库 创建句柄
40
  bm, err := cache.NewCache("redis", string(redis_config) )
41
  if err != nil {
42
    beego.Info("缓存创建失败",err)
43
    rsp.Errno  =  utils.RECODE_DBERR
44
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
45
    return  nil
46
  }
47
  //拼接key
48
  sessioniduserid :=  req.Sessionid + "user_id"
49

50
  //获得当前用户的userid
51
  value_id :=bm.Get(sessioniduserid)
52
  beego.Info(value_id,reflect.TypeOf(value_id))
53

54

55
  id :=  int(value_id.([]uint8)[0])
56
  beego.Info(id ,reflect.TypeOf(id))
57

58
  //创建表对象
59
  user := models.User{Id:id,Avatar_url:FileId}
60
  /*将当前fastdfs-url 存储到我们当前用户的表中*/
61
  o:=orm.NewOrm()
62
  //将图片的地址存入表中
63
  _ ,err =o.Update(&user ,"avatar_url")
64
  if err !=nil {
65

66
    rsp.Errno = utils.RECODE_DBERR
67
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
68

69
  }
70

71
  //回传图片地址
72
  rsp.AvatarUrl=FileId
73

74
  return nil
75
}

1
package models
2

3
import (
4
  "github.com/weilaihui/fdfs_client"
5
  "github.com/astaxie/beego"
6
)
7

8

9
//通过文件名的方式进行上传
10
func UploadByFilename( filename string)(GroupName,RemoteFileId string ,err error ) {
11
  //通过配置文件创建fdfs操作句柄
12
  fdfsClient, thiserr :=fdfs_client.NewFdfsClient("/home/itcast/go/srcsss/homeweb/conf/client.conf")
13
  if thiserr  !=nil{
14
    //说一下那里出问题了
15
    beego.Info("UploadByFilename( ) fdfs_client.NewFdfsClient  err",err)
16
    GroupName = ""
17
    RemoteFileId = ""
18
    err = thiserr
19
    return
20
  }
21

22
  //unc (this *FdfsClient) UploadByFilename(filename string) (*UploadFileResponse, error)
23
  //通过句柄上传文件（被上传的文件）
24

25
  uploadResponse, thiserr := fdfsClient.UploadByFilename(filename)
26
  if thiserr !=nil{
27
    beego.Info("UploadByFilename( ) fdfsClient.UploadByFilename(filename)  err",err)
28
    GroupName = ""
29
    RemoteFileId = ""
30
    err = thiserr
31
    return
32
  }
33

34
  beego.Info(uploadResponse.GroupName)
35
  beego.Info(uploadResponse.RemoteFileId)
36
  //回传
37
  return  uploadResponse.GroupName , uploadResponse.RemoteFileId ,nil
38

39
}
40

41
//功能函数 操作fdfs上传二进制文件
42
func UploadByBuffer(filebuffer []byte, fileExtName string)(GroupName,RemoteFileId string ,err error ){
43

44
  //通过配置文件创建fdfs操作句柄
45
  fdfsClient, thiserr :=fdfs_client.NewFdfsClient("/home/itcast/go/src/sss/homeweb/conf/client.conf")
46
  if thiserr  !=nil{
47
    beego.Info("UploadByBuffer( ) fdfs_client.NewFdfsClient  err",err)
48
    GroupName = ""
49
    RemoteFileId = ""
50
    err = thiserr
51
    return
52
  }
53

54
  //通过句柄上传二进制的文件
55
  uploadResponse, thiserr :=fdfsClient.UploadByBuffer(filebuffer,fileExtName)
56
  if thiserr  !=nil{
57
    beego.Info("UploadByBuffer( ) fdfs_client.UploadByBuffer  err",err)
58
    GroupName = ""
59
    RemoteFileId = ""
60
    err = thiserr
61
    return
62
  }
63
  beego.Info(uploadResponse.GroupName)
64
  beego.Info(uploadResponse.RemoteFileId)
65
  //回传
66
  return uploadResponse.GroupName,uploadResponse.RemoteFileId,nil
67

68
}