订阅发布消息以实现 Github 用户名搜索

2023-11-15 17:17:51

利用消息订阅和预发布实现高效的 GitHub 用户名模糊搜索

简介

在快节奏的数字时代，快速而准确地获取信息至关重要。为了满足这一需求，本文将介绍如何使用消息订阅和预发布技术打造一个强大的 GitHub 用户名模糊搜索功能，帮助您轻松查找所需的信息。

准备工作

在着手构建搜索功能之前，需要完成以下准备工作：

1. 安装依赖项

npm i axios pubsub-js

2. 创建 Pub/Sub 主题和订阅

主题是消息的发布目的地，而订阅则是接收消息的渠道。使用 Google Cloud Console 或 Pub/Sub API 创建主题和订阅。

实现搜索功能

1. 创建数据库表

在 Cloud SQL 中创建一张数据库表来存储 GitHub 用户名数据：

CREATE TABLE github_usernames (
  id INT NOT NULL AUTO_INCREMENT,
  username VARCHAR(255) NOT NULL,
  PRIMARY KEY (id)
);

2. 插入数据

将一些 GitHub 用户名数据插入表中：

INSERT INTO github_usernames (username) VALUES ('john_doe');
INSERT INTO github_usernames (username) VALUES ('jane_doe');
INSERT INTO github_usernames (username) VALUES ('bill_gates');

3. 编写代码

在 Node.js 中使用 Pub/Sub 和 Axios 编写搜索代码：

const axios = require('axios');
const pubsub = require('pubsub-js');

// 创建 Pub/Sub 主题和订阅
const topic = pubsub.topic('github-usernames');
const subscription = pubsub.subscribe('github-usernames-subscription', (message) => {
  // 从消息中获取搜索查询
  const query = message.data;

  // 使用 Axios 查询数据库
  axios.get(`http://localhost:3306/github_usernames?q=${query}`)
    .then((response) => {
      // 获取搜索结果
      const results = response.data;

      // 将结果发布到主题
      topic.publish(results);
    })
    .catch((error) => {
      console.error(error);
    });
});

// 监听主题消息
topic.on('message', (message) => {
  // 获取搜索结果
  const results = message.data;

  // 在控制台打印结果
  console.log(results);
});

// 发布搜索查询
topic.publish('john_doe');