深圳幻海软件技术有限公司 欢迎您！
更多

构建一个即时消息应用（一）：模式

2023-02-27

null 消息 not
这是一系列关于构建“即时消息”应用的新帖子。你应该对这类应用并不陌生。有了它们的帮助，我们才可以与朋友畅聊无忌。FacebookMessenger、WhatsApp和Skype就是其中的几个例子。正如你所看到的那样，这些应用允许我们发送图片、传输视频、录制音频、以及和一大帮子人聊天等等。当然，我们的

这是一系列关于构建“即时消息”应用的新帖子。你应该对这类应用并不陌生。有了它们的帮助，我们才可以与朋友畅聊无忌。Facebook Messenger、WhatsApp 和 Skype 就是其中的几个例子。正如你所看到的那样，这些应用允许我们发送图片、传输视频、录制音频、以及和一大帮子人聊天等等。当然，我们的教程应用将会尽量保持简单，只在两个用户之间发送文本消息。

我们将会用 CockroachDB 作为 SQL 数据库，用 Go 作为后端语言，并且用 JavaScript 来制作 web 应用。

这是头篇帖子，我们将会讲述数据库的设计。

  1. CREATE TABLE users (
  2.     id SERIAL NOT NULL PRIMARY KEY,
  3.     username STRING NOT NULL UNIQUE,
  4.     avatar_url STRING,
  5.     github_id INT NOT NULL UNIQUE
  6. );
  • 1.
  • 2.
  • 3.
  • 4.
  • 5.
  • 6.

显然，这个应用需要一些用户。我们这里采用社交登录的形式。由于我选用了 GitHub，所以这里需要保存一个对 GitHub 用户 ID 的引用。

  1. CREATE TABLE conversations (
  2.     id SERIAL NOT NULL PRIMARY KEY,
  3.     last_message_id INT,
  4.     INDEX (last_message_id DESC)
  5. );
  • 1.
  • 2.
  • 3.
  • 4.
  • 5.

每个对话都会引用最近一条消息。每当我们输入一条新消息时，我们都会更新这个字段。我会在后面添加外键约束。

… 你可能会想，我们可以先对对话进行分组，然后再通过这样的方式获取最近一条消息。但这样做会使查询变得更加复杂。

  1. CREATE TABLE participants (
  2.     user_id INT NOT NULL REFERENCES users ON DELETE CASCADE,
  3.     conversation_id INT NOT NULL REFERENCES conversations ON DELETE CASCADE,
  4.     messages_read_at TIMESTAMPTZ NOT NULL DEFAULT now(),
  5.     PRIMARY KEY (user_id, conversation_id)
  6. );
  • 1.
  • 2.
  • 3.
  • 4.
  • 5.
  • 6.

尽管之前我提到过对话只会在两个用户之间进行，但我们还是采用了允许向对话中添加多个参与者的设计。因此，在对话和用户之间有一个参与者表。

为了知道用户是否有未读消息，我们在消息表中添加了“读取时间”（messages_read_at）字段。每当用户在对话中读取消息时，我们都会更新它的值，这样一来，我们就可以将它与对话中末尾一条消息的“创建时间”（created_at）字段进行比较。

  1. CREATE TABLE messages (
  2.     id SERIAL NOT NULL PRIMARY KEY,
  3.     content STRING NOT NULL,
  4.     user_id INT NOT NULL REFERENCES users ON DELETE CASCADE,
  5.     conversation_id INT NOT NULL REFERENCES conversations ON DELETE CASCADE,
  6.     created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
  7.     INDEX(created_at DESC)
  8. );
  • 1.
  • 2.
  • 3.
  • 4.
  • 5.
  • 6.
  • 7.
  • 8.

尽管我们将消息表放在末尾，但它在应用中相当重要。我们用它来保存对创建它的用户以及它所出现的对话的引用。而且还可以根据“创建时间”（created_at）来创建索引以完成对消息的排序。

  1. ALTER TABLE conversations
  2. ADD CONSTRAINT fk_last_message_id_ref_messages
  3. FOREIGN KEY (last_message_id) REFERENCES messages ON DELETE SET NULL;
  • 1.
  • 2.
  • 3.

我在前面已经提到过这个外键约束了，不是吗:D

有这四张表就足够了。你也可以将这些查询保存到一个文件中，并将其通过管道传送到 Cockroach CLI。

首先，我们需要启动一个新节点：

  1. cockroach start --insecure --host 127.0.0.1
  • 1.

然后创建数据库和这些表：

  1. cockroach sql --insecure -e "CREATE DATABASE messenger"
  2. cat schema.sql | cockroach sql --insecure -d messenger
  • 1.
  • 2.

这篇帖子就到这里。 

 

如何两天时间上线一款AI应用？
用自己的编程语言实现了一个网站（增强版）