Node.js 및 Pulsetracker&#s Redis Pub/Sub를 사용한 실시간 위치 추적-JS 튜토리얼-php.cn

Node.js 및 Pulsetracker&#s Redis Pub/Sub를 사용한 실시간 위치 추적

DDD

풀어 주다： 2024-12-09 13:20:10

원래의

633명이 탐색했습니다.

Real-Time Location Tracking with Node.js and Pulsetracker

소개

실시간 위치 추적은 배달 서비스부터 개인 추적 도구에 이르기까지 많은 최신 애플리케이션의 핵심입니다. Pulsetracker는 개발자가 백엔드에서 실시간 위치 업데이트를 구독할 수 있는 전용 Redis Pub/Sub 서버를 제공하여 이 프로세스를 단순화합니다. 이 가이드에서는 이러한 업데이트를 수신하고 위치 데이터를 실시간으로 처리하는 Node.js 애플리케이션을 구축하는 방법을 보여줍니다.

Pulsetracker를 사용해야 하는 이유

Pulsetracker는 실시간 위치 추적을 위한 백엔드 구축의 복잡성을 제거합니다. WebSocket 디스패칭, Redis Pub/Sub 통합, 구성 가능한 개인정보 보호 설정 등 개인정보 보호에 초점을 맞춘 옵션과 기능을 갖춘 확장 가능한 인프라를 제공합니다.

왜 Node.js를 사용하나요?

Node.js는 비차단 이벤트 기반 아키텍처로 인해 실시간 애플리케이션을 위한 완벽한 선택입니다. Node.js에서 Redis Pub/Sub를 사용하면 실시간 데이터 스트림을 효율적으로 처리할 수 있습니다.

Node.js 환경 설정

전제 조건:

Node.js 설치
Redis 클라이언트 라이브러리(ioredis) 설치
Pulsetracker 계정 및 API 자격 증명

1단계: 종속성 설치

다음 명령을 실행하여 필요한 Redis 라이브러리를 설치하세요.

npm install ioredis

로그인 후 복사

2단계: 애플리케이션 구성

.env 파일을 생성하고 Pulsetracker Redis 구성을 추가하세요.
(pulsestracker 대시보드에서 APP_KEY 및 TOKEN을 받으세요)

PULSETRACKER_REDIS_URL=redis://redis-sub.pulsestracker.com:6378
APP_KEY=YOUR_APP_KEY
TOKEN=YOUR_TOKEN

로그인 후 복사

3단계: Node.js 구독자 작성

다음은 위치 업데이트를 수신하는 Node.js 스크립트의 예입니다.

const Redis = require("ioredis");
require("dotenv").config();

// Configuration
const redisUrl = process.env.PULSETRACKER_REDIS_URL;
const appKey = process.env.APP_KEY;
const token = process.env.TOKEN;

// Generate the signature
function generateSignature(appKey, token) {
  const crypto = require("crypto");
  const [prefix, secret] = token.split("|");
  if (!secret) throw new Error("Invalid token format");

  const innerHash = crypto.createHash("sha256").update(secret).digest("hex");
  return crypto.createHmac("sha256", innerHash).update(appKey).digest("hex");
}

const signature = generateSignature(appKey, token);
const channel = `app:${appKey}.${signature}`;

// Connect to Redis
const redis = new Redis(redisUrl);

console.log(`Subscribing to channel: ${channel}`);
redis.subscribe(channel, (err, count) => {
  if (err) {
    console.error("Failed to subscribe:", err);
    process.exit(1);
  }
  console.log(`Successfully subscribed. Waiting for messages...`);
});

// Listen for messages
redis.on("message", (channel, message) => {
  console.log(`Received message ${message}`);
});

로그인 후 복사

작동 방식