av激情亚洲男人的天堂国语,日韩欧美精品一中文字幕,无码av一区二区三区无码,国产又色又爽又刺激的a片,国产又色又爽又刺激的a片

構(gòu)建一個(gè)即時(shí)消息應(yīng)用（三）：對(duì)話

本文是該系列的第三篇。

公司主營(yíng)業(yè)務(wù)：做網(wǎng)站、網(wǎng)站建設(shè)、移動(dòng)網(wǎng)站開發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競(jìng)爭(zhēng)能力。創(chuàng)新互聯(lián)公司是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對(duì)我們的高要求，感謝他們從不同領(lǐng)域給我們帶來的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶帶來驚喜。創(chuàng)新互聯(lián)公司推出江南免費(fèi)做網(wǎng)站回饋大家。

  • 第一篇：模式
  • 第二篇：OAuth

在我們的即時(shí)消息應(yīng)用中，消息表現(xiàn)為兩個(gè)參與者對(duì)話的堆疊。如果你想要開始一場(chǎng)對(duì)話，就應(yīng)該向應(yīng)用提供你想要交談的用戶，而當(dāng)對(duì)話創(chuàng)建后（如果該對(duì)話此前并不存在），就可以向該對(duì)話發(fā)送消息。

就前端而言，我們可能想要顯示一份近期對(duì)話列表。并在此處顯示對(duì)話的最后一條消息以及另一個(gè)參與者的姓名和頭像。

在這篇帖子中，我們將會(huì)編寫一些端點(diǎn)endpoint來完成像“創(chuàng)建對(duì)話”、“獲取對(duì)話列表”以及“找到單個(gè)對(duì)話”這樣的任務(wù)。

首先，要在主函數(shù) main() 中添加下面的路由。

 
 
 
    
  
  
  
  1. router.HandleFunc("POST", "/api/conversations", requireJSON(guard(createConversation)))
    2. 
  
  
  
  2. router.HandleFunc("GET", "/api/conversations", guard(getConversations))
    3. 
  
  
  
  3. router.HandleFunc("GET", "/api/conversations/:conversationID", guard(getConversation))
    4.

這三個(gè)端點(diǎn)都需要進(jìn)行身份驗(yàn)證，所以我們將會(huì)使用 guard() 中間件。我們也會(huì)構(gòu)建一個(gè)新的中間件，用于檢查請(qǐng)求內(nèi)容是否為 JSON 格式。

JSON 請(qǐng)求檢查中間件

 
 
 
    
  
  
  
  1. func requireJSON(handler http.HandlerFunc) http.HandlerFunc {
    2. 
  
  
  
  2.  return func(w http.ResponseWriter, r *http.Request) {
    3. 
  
  
  
  3.  if ct := r.Header.Get("Content-Type"); !strings.HasPrefix(ct, "application/json") {
    4. 
  
  
  
  4.  http.Error(w, "Content type of application/json required", http.StatusUnsupportedMediaType)
    5. 
  
  
  
  5.  return
    6. 
  
  
  
  6.  }
    7. 
  
  
  
  7.  handler(w, r)
    8. 
  
  
  
  8.  }
    9. 
  
  
  
  9. }
    10.

如果請(qǐng)求request不是 JSON 格式，那么它會(huì)返回 415 Unsupported Media Type（不支持的媒體類型）錯(cuò)誤。

創(chuàng)建對(duì)話

 
 
 
    
  
  
  
  1. type Conversation struct {
    2. 
  
  
  
  2.  ID string `json:"id"`
    3. 
  
  
  
  3.  OtherParticipant *User `json:"otherParticipant"`
    4. 
  
  
  
  4.  LastMessage *Message `json:"lastMessage"`
    5. 
  
  
  
  5.  HasUnreadMessages bool `json:"hasUnreadMessages"`
    6. 
  
  
  
  6. }
    7.

就像上面的代碼那樣，對(duì)話中保持對(duì)另一個(gè)參與者和最后一條消息的引用，還有一個(gè) bool 類型的字段，用來告知是否有未讀消息。

 
 
 
    
  
  
  
  1. type Message struct {
    2. 
  
  
  
  2.  ID string `json:"id"`
    3. 
  
  
  
  3.  Content string `json:"content"`
    4. 
  
  
  
  4.  UserID string `json:"-"`
    5. 
  
  
  
  5.  ConversationID string `json:"conversationID,omitempty"`
    6. 
  
  
  
  6.  CreatedAt time.Time `json:"createdAt"`
    7. 
  
  
  
  7.  Mine bool `json:"mine"`
    8. 
  
  
  
  8.  ReceiverID string `json:"-"`
    9. 
  
  
  
  9. }
    10.

我們會(huì)在下一篇文章介紹與消息相關(guān)的內(nèi)容，但由于我們這里也需要用到它，所以先定義了 Message 結(jié)構(gòu)體。其中大多數(shù)字段與數(shù)據(jù)庫(kù)表一致。我們需要使用 Mine 來斷定消息是否屬于當(dāng)前已驗(yàn)證用戶所有。一旦加入實(shí)時(shí)功能，ReceiverID 可以幫助我們過濾消息。

接下來讓我們編寫 HTTP 處理程序。盡管它有些長(zhǎng)，但也沒什么好怕的。

 
 
 
    
  
  
  
  1. func createConversation(w http.ResponseWriter, r *http.Request) {
    2. 
  
  
  
  2.  var input struct {
    3. 
  
  
  
  3.  Username string `json:"username"`
    4. 
  
  
  
  4.  }
    5. 
  
  
  
  5.  defer r.Body.Close()
    6. 
  
  
  
  6.  if err := json.NewDecoder(r.Body).Decode(&input); err != nil {
    7. 
  
  
  
  7.  http.Error(w, err.Error(), http.StatusBadRequest)
    8. 
  
  
  
  8.  return
    9. 
  
  
  
  9.  }
    10. 
  
  
  
  10. 
  
  
  
  11.  input.Username = strings.TrimSpace(input.Username)
    12. 
  
  
  
  12.  if input.Username == "" {
    13. 
  
  
  
  13.  respond(w, Errors{map[string]string{
    14. 
  
  
  
  14.  "username": "Username required",
    15. 
  
  
  
  15.  }}, http.StatusUnprocessableEntity)
    16. 
  
  
  
  16.  return
    17. 
  
  
  
  17.  }
    18. 
  
  
  
  18. 
  
  
  
  19.  ctx := r.Context()
    20. 
  
  
  
  20.  authUserID := ctx.Value(keyAuthUserID).(string)
    21. 
  
  
  
  21. 
  
  
  
  22.  tx, err := db.BeginTx(ctx, nil)
    23. 
  
  
  
  23.  if err != nil {
    24. 
  
  
  
  24.  respondError(w, fmt.Errorf("could not begin tx: %v", err))
    25. 
  
  
  
  25.  return
    26. 
  
  
  
  26.  }
    27. 
  
  
  
  27.  defer tx.Rollback()
    28. 
  
  
  
  28. 
  
  
  
  29.  var otherParticipant User
    30. 
  
  
  
  30.  if err := tx.QueryRowContext(ctx, `
    31. 
  
  
  
  31.  SELECT id, avatar_url FROM users WHERE username = $1
    32. 
  
  
  
  32.  `, input.Username).Scan(
    33. 
  
  
  
  33.  &otherParticipant.ID,
    34. 
  
  
  
  34.  &otherParticipant.AvatarURL,
    35. 
  
  
  
  35.  ); err == sql.ErrNoRows {
    36. 
  
  
  
  36.  http.Error(w, "User not found", http.StatusNotFound)
    37. 
  
  
  
  37.  return
    38. 
  
  
  
  38.  } else if err != nil {
    39. 
  
  
  
  39.  respondError(w, fmt.Errorf("could not query other participant: %v", err))
    40. 
  
  
  
  40.  return
    41. 
  
  
  
  41.  }
    42. 
  
  
  
  42. 
  
  
  
  43.  otherParticipant.Username = input.Username
    44. 
  
  
  
  44. 
  
  
  
  45.  if otherParticipant.ID == authUserID {
    46. 
  
  
  
  46.  http.Error(w, "Try start a conversation with someone else", http.StatusForbidden)
    47. 
  
  
  
  47.  return
    48. 
  
  
  
  48.  }
    49. 
  
  
  
  49. 
  
  
  
  50.  var conversationID string
    51. 
  
  
  
  51.  if err := tx.QueryRowContext(ctx, `
    52. 
  
  
  
  52.  SELECT conversation_id FROM participants WHERE user_id = $1
    53. 
  
  
  
  53.  INTERSECT
    54. 
  
  
  
  54.  SELECT conversation_id FROM participants WHERE user_id = $2
    55. 
  
  
  
  55.  `, authUserID, otherParticipant.ID).Scan(&conversationID); err != nil && err != sql.ErrNoRows {
    56. 
  
  
  
  56.  respondError(w, fmt.Errorf("could not query common conversation id: %v", err))
    57. 
  
  
  
  57.  return
    58. 
  
  
  
  58.  } else if err == nil {
    59. 
  
  
  
  59.  http.Redirect(w, r, "/api/conversations/"+conversationID, http.StatusFound)
    60. 
  
  
  
  60.  return
    61. 
  
  
  
  61.  }
    62. 
  
  
  
  62. 
  
  
  
  63.  var conversation Conversation
    64. 
  
  
  
  64.  if err = tx.QueryRowContext(ctx, `
    65. 
  
  
  
  65.  INSERT INTO conversations DEFAULT VALUES
    66. 
  
  
  
  66.  RETURNING id
    67. 
  
  
  
  67.  `).Scan(&conversation.ID); err != nil {
    68. 
  
  
  
  68.  respondError(w, fmt.Errorf("could not insert conversation: %v", err))
    69. 
  
  
  
  69.  return
    70. 
  
  
  
  70.  }
    71. 
  
  
  
  71. 
  
  
  
  72.  if _, err = tx.ExecContext(ctx, `
    73. 
  
  
  
  73.  INSERT INTO participants (user_id, conversation_id) VALUES
    74. 
  
  
  
  74.  ($1, $2),
    75. 
  
  
  
  75.  ($3, $2)
    76. 
  
  
  
  76.  `, authUserID, conversation.ID, otherParticipant.ID); err != nil {
    77. 
  
  
  
  77.  respondError(w, fmt.Errorf("could not insert participants: %v", err))
    78. 
  
  
  
  78.  return
    79. 
  
  
  
  79.  }
    80. 
  
  
  
  80. 
  
  
  
  81.  if err = tx.Commit(); err != nil {
    82. 
  
  
  
  82.  respondError(w, fmt.Errorf("could not commit tx to create conversation: %v", err))
    83. 
  
  
  
  83.  return
    84. 
  
  
  
  84.  }
    85. 
  
  
  
  85. 
  
  
  
  86.  conversation.OtherParticipant = &otherParticipant
    87. 
  
  
  
  87. 
  
  
  
  88.  respond(w, conversation, http.StatusCreated)
    89. 
  
  
  
  89. }
    90.

在此端點(diǎn)，你會(huì)向 /api/conversations 發(fā)送 POST 請(qǐng)求，請(qǐng)求的 JSON 主體中包含要對(duì)話的用戶的用戶名。

因此，首先需要將請(qǐng)求主體解析成包含用戶名的結(jié)構(gòu)。然后，校驗(yàn)用戶名不能為空。

 
 
 
    
  
  
  
  1. type Errors struct {
    2. 
  
  
  
  2.  Errors map[string]string `json:"errors"`
    3. 
  
  
  
  3. }
    4.

這是錯(cuò)誤消息的結(jié)構(gòu)體 Errors，它僅僅是一個(gè)映射。如果輸入空用戶名，你就會(huì)得到一段帶有 422 Unprocessable Entity（無法處理的實(shí)體）錯(cuò)誤消息的 JSON 。

 
 
 
    
  
  
  
  1. {
    2. 
  
  
  
  2.  "errors": {
    3. 
  
  
  
  3.  "username": "Username required"
    4. 
  
  
  
  4.  }
    5. 
  
  
  
  5. }
    6.

然后，我們開始執(zhí)行 SQL 事務(wù)。收到的僅僅是用戶名，但事實(shí)上，我們需要知道實(shí)際的用戶 ID 。因此，事務(wù)的第一項(xiàng)內(nèi)容是查詢另一個(gè)參與者的 ID 和頭像。如果找不到該用戶，我們將會(huì)返回 404 Not Found（未找到） 錯(cuò)誤。另外，如果找到的用戶恰好和“當(dāng)前已驗(yàn)證用戶”相同，我們應(yīng)該返回 403 Forbidden（拒絕處理）錯(cuò)誤。這是由于對(duì)話只應(yīng)當(dāng)在兩個(gè)不同的用戶之間發(fā)起，而不能是同一個(gè)。

然后，我們?cè)噲D找到這兩個(gè)用戶所共有的對(duì)話，所以需要使用 INTERSECT 語句。如果存在，只需要通過 /api/conversations/{conversationID} 重定向到該對(duì)話并將其返回。

如果未找到共有的對(duì)話，我們需要?jiǎng)?chuàng)建一個(gè)新的對(duì)話并添加指定的兩個(gè)參與者。最后，我們 COMMIT 該事務(wù)并使用新創(chuàng)建的對(duì)話進(jìn)行響應(yīng)。

獲取對(duì)話列表

端點(diǎn) /api/conversations 將獲取當(dāng)前已驗(yàn)證用戶的所有對(duì)話。

 
 
 
    
  
  
  
  1. func getConversations(w http.ResponseWriter, r *http.Request) {
    2. 
  
  
  
  2.  ctx := r.Context()
    3. 
  
  
  
  3.  authUserID := ctx.Value(keyAuthUserID).(string)
    4. 
  
  
  
  4. 
  
  
  
  5.  rows, err := db.QueryContext(ctx, `
    6. 
  
  
  
  6.  SELECT
    7. 
  
  
  
  7.  conversations.id,
    8. 
  
  
  
  8.  auth_user.messages_read_at < messages.created_at AS has_unread_messages,
    9. 
  
  
  
  9.  messages.id,
    10. 
  
  
  
  10.  messages.content,
    11. 
  
  
  
  11.  messages.created_at,
    12. 
  
  
  
  12.  messages.user_id = $1 AS mine,
    13. 
  
  
  
  13.  other_users.id,
    14. 
  
  
  
  14.  other_users.username,
    15. 
  
  
  
  15.  other_users.avatar_url
    16. 
  
  
  
  16.  FROM conversations
    17. 
  
  
  
  17.  INNER JOIN messages ON conversations.last_message_id = messages.id
    18. 
  
  
  
  18.  INNER JOIN participants other_participants
    19. 
  
  
  
  19.  ON other_participants.conversation_id = conversations.id
    20. 
  
  
  
  20.  AND other_participants.user_id != $1
    21. 
  
  
  
  21.  INNER JOIN users other_users ON other_participants.user_id = other_users.id
    22. 
  
  
  
  22.  INNER JOIN participants auth_user
    23. 
  
  
  
  23.  ON auth_user.conversation_id = conversations.id
    24. 
  
  
  
  24.  AND auth_user.user_id = $1
    25. 
  
  
  
  25.  ORDER BY messages.created_at DESC
    26. 
  
  
  
  26.  `, authUserID)
    27. 
  
  
  
  27.  if err != nil {
    28. 
  
  
  
  28.  respondError(w, fmt.Errorf("could not query conversations: %v", err))
    29. 
  
  
  
  29.  return
    30. 
  
  
  
  30.  }
    31. 
  
  
  
  31.  defer rows.Close()
    32. 
  
  
  
  32. 
  
  
  
  33.  conversations := make([]Conversation, 0)
    34. 
  
  
  
  34.  for rows.Next() {
    35. 
  
  
  
  35.  var conversation Conversation
    36. 
  
  
  
  36.  var lastMessage Message
    37. 
  
  
  
  37.  var otherParticipant User
    38. 
  
  
  
  38.  if err = rows.Scan(
    39. 
  
  
  
  39.  &conversation.ID,
    40. 
  
  
  
  40.  &conversation.HasUnreadMessages,
    41. 
  
  
  
  41.  &lastMessage.ID,
    42. 
  
  
  
  42.  &lastMessage.Content,
    43. 
  
  
  
  43.  &lastMessage.CreatedAt,
    44. 
  
  
  
  44.  &lastMessage.Mine,
    45. 
  
  
  
  45.  &otherParticipant.ID,
    46. 
  
  
  
  46.  &otherParticipant.Username,
    47. 
  
  
  
  47.  &otherParticipant.AvatarURL,
    48. 
  
  
  
  48.  ); err != nil {
    49. 
  
  
  
  49.  respondError(w, fmt.Errorf("could not scan conversation: %v", err))
    50. 
  
  
  
  50.  return
    51. 
  
  
  
  51.  }
    52. 
  
  
  
  52. 
  
  
  
  53.  conversation.LastMessage = &lastMessage
    54. 
  
  
  
  54.  conversation.OtherParticipant = &otherParticipant
    55. 
  
  
  
  55.  conversations = append(conversations, conversation)
    56. 
  
  
  
  56.  }
    57. 
  
  
  
  57. 
  
  
  
  58.  if err = rows.Err(); err != nil {
    59. 
  
  
  
  59.  respondError(w, fmt.Errorf("could not iterate over conversations: %v", err))
    60. 
  
  
  
  60.  return
    61. 
  
  
  
  61.  }
    62. 
  
  
  
  62. 
  
  
  
  63.  respond(w, conversations, http.StatusOK)
    64. 
  
  
  
  64. }
    65.

該處理程序僅對(duì)數(shù)據(jù)庫(kù)進(jìn)行查詢。它通過一些聯(lián)接來查詢對(duì)話表……首先，從消息表中獲取最后一條消息。然后依據(jù)“ID 與當(dāng)前已驗(yàn)證用戶不同”的條件，從參與者表找到對(duì)話的另一個(gè)參與者。然后聯(lián)接到用戶表以獲取該用戶的用戶名和頭像。最后，再次聯(lián)接參與者表，并以相反的條件從該表中找出參與對(duì)話的另一個(gè)用戶，其實(shí)就是當(dāng)前已驗(yàn)證用戶。我們會(huì)對(duì)比消息中的 messages_read_at 和 created_at 兩個(gè)字段，以確定對(duì)話中是否存在未讀消息。然后，我們通過 user_id 字段來判定該消息是否屬于“我”（指當(dāng)前已驗(yàn)證用戶）。

注意，此查詢過程假定對(duì)話中只有兩個(gè)用戶參與，它也僅僅適用于這種情況。另外,該設(shè)計(jì)也不很適用于需要顯示未讀消息數(shù)量的情況。如果需要顯示未讀消息的數(shù)量，我認(rèn)為可以在 participants 表上添加一個(gè)unread_messages_count INT 字段，并在每次創(chuàng)建新消息的時(shí)候遞增它，如果用戶已讀則重置該字段。

接下來需要遍歷每一條記錄，通過掃描每一個(gè)存在的對(duì)話來建立一個(gè)對(duì)話切片slice of conversations并在最后進(jìn)行響應(yīng)。

找到單個(gè)對(duì)話

端點(diǎn) /api/conversations/{conversationID} 會(huì)根據(jù) ID 對(duì)單個(gè)對(duì)話進(jìn)行響應(yīng)。

 
 
 
    
  
  
  
  1. func getConversation(w http.ResponseWriter, r *http.Request) {
    2. 
  
  
  
  2.  ctx := r.Context()
    3. 
  
  
  
  3.  authUserID := ctx.Value(keyAuthUserID).(string)
    4. 
  
  
  
  4.  conversationID := way.Param(ctx, "conversationID")
    5. 
  
  
  
  5. 
  
  
  
  6.  var conversation Conversation
    7. 
  
  
  
  7.  var otherParticipant User
    8. 
  
  
  
  8.  if err := db.QueryRowContext(ctx, `
    9. 
  
  
  
  9.  SELECT
    10. 
  
  
  
  10.  IFNULL(auth_user.messages_read_at < messages.created_at, false) AS has_unread_messages,
    11. 
  
  
  
  11.  other_users.id,
    12. 
  
  
  
  12.  other_users.username,
    13. 
  
  
  
  13.  other_users.avatar_url
    14. 
  
  
  
  14.  FROM conversations
    15. 
  
  
  
  15.  LEFT JOIN messages ON conversations.last_message_id = messages.id
    16. 
  
  
  
  16.  INNER JOIN participants other_participants
    17. 
  
  
  
  17.  ON other_participants.conversation_id = conversations.id
    18. 
  
  
  
  18.  AND other_participants.user_id != $1
    19. 
  
  
  
  19.  INNER JOIN users other_users ON other_participants.user_id = other_users.id
    20. 
  
  
  
  20.  INNER JOIN participants auth_user
    21. 
  
  
  
  21.  ON auth_user.conversation_id = conversations.id
    22. 
  
  
  
  22.  AND auth_user.user_id = $1
    23. 
  
  
  
  23.  WHERE conversations.id = $2
    24. 
  
  
  
  24.  `, authUserID, conversationID).Scan(
    25. 
  
  
  
  25.  &conversation.HasUnreadMessages,
    26. 
  
  
  
  26.  &otherParticipant.ID,
    27. 
  
  
  
  27.  &otherParticipant.Username,
    28. 
  
  
  
  28.  &otherParticipant.AvatarURL,
    29. 
  
  
  
  29.  ); err == sql.ErrNoRows {
    30. 
  
  
  
  30.  http.Error(w, "Conversation not found", http.StatusNotFound)
    31. 
  
  
  
  31.  return
    32. 
  
  
  
  32.  } else if err != nil {
    33. 
  
  
  
  33.  respondError(w, fmt.Errorf("could not query conversation: %v", err))
    34. 
  
  
  
  34.  return
    35. 
  
  
  
  35.  }
    36. 
  
  
  
  36. 
  
  
  
  37.  conversation.ID = conversationID
    38. 
  
  
  
  38.  conversation.OtherParticipant = &otherParticipant
    39. 
  
  
  
  39. 
  
  
  
  40.  respond(w, conversation, http.StatusOK)
    41. 
  
  
  
  41. }
    42.

這里的查詢與之前有點(diǎn)類似。盡管我們并不關(guān)心最后一條消息的顯示問題，并因此忽略了與之相關(guān)的一些字段，但是我們需要根據(jù)這條消息來判斷對(duì)話中是否存在未讀消息。此時(shí)，我們使用 LEFT JOIN 來代替 INNER JOIN，因?yàn)?last_message_id 字段是 NULLABLE（可以為空）的；而其他情況下，我們無法得到任何記錄?；谕瑯拥睦碛桑覀?cè)?has_unread_messages 的比較中使用了 IFNULL 語句。最后，我們按 ID 進(jìn)行過濾。

如果查詢沒有返回任何記錄，我們的響應(yīng)會(huì)返回 404 Not Found 錯(cuò)誤，否則響應(yīng)將會(huì)返回 200 OK 以及找到的對(duì)話。

本篇帖子以創(chuàng)建了一些對(duì)話端點(diǎn)結(jié)束。

在下一篇帖子中，我們將會(huì)看到如何創(chuàng)建并列出消息。

  • 源代碼

當(dāng)前題目：構(gòu)建一個(gè)即時(shí)消息應(yīng)用（三）：對(duì)話
分享網(wǎng)址：http://uogjgqi.cn/article/cdgejcd.html
掃二維碼與項(xiàng)目經(jīng)理溝通

我們?cè)谖⑿派?4小時(shí)期待你的聲音

解答本文疑問/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流