Redis Adapter emits message twice

Aperta
  • Qualcosa non va?
#477 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
3/5
Tempo stimato
1-2 giorni
Idoneità per principianti
42/100
Tipo di issue
Bug
Chiarezza
Abbastanza chiara
Stato di attività
Ferma
Stack tecnologico
javascript, redis
Ambito
backend, distributed-systems

Direzione di ricerca

Start by running the reproduction code in the issue with Redis enabled and then disabled, comparing how many times client-2 receives the member:message event and how the callback responds. The fix is complete when the Redis adapter path delivers the message once while preserving the callback-to-server and callback-to-client-1 flow.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

When I use callbacks and I follow this pattern client-1 -> server -> client-2 -> callback-to-server -> callback-to-client-1 the adapter appears to send messages twice to client-2. Here is replication code. When I comment out all redis things it will only send once

Server

`const socketIo = require("socket.io");
const redisAdapter = require("@socket.io/redis-adapter");
const redis = require("redis");

const io = new socketIo.Server(
{
cors: {
origin: process.env.ORIGIN,
methods: ["GET", "POST"],
credentials: true,
},
}
);

let ns = io.of('/');

const pubClient = redis.createClient({ url: "redisurl" });
const subClient = pubClient.duplicate();

Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
io.adapter(redisAdapter.createAdapter(pubClient, subClient));
io.listen(PORT);
});

pubClient.on('connect', () => {
console.log('::> Redis Client Connected');
});
pubClient.on('error', (err) => {
console.log('<:: Redis Client Error', err);
});

ns.on("connection", async (socket) => {
socket.on("host:broadcast", async (data, callback) => {
const room = socket.to(data.room);
room.emit("member:message", data, (arg) => {
callback(arg);
});
});
});

`

Lingua principale
TypeScript
Stelle
2.8k
Fork
485
Nessuna PR unita negli ultimi 30g

Preparare l'ambiente

  • Include un Dockerfile o un file Docker Compose
  • Nessun modello di pull request
  • Nessuna guida per i contributori

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di socketio/socket.io-redis-adapter

Tutte le issue di socketio/socket.io-redis-adapter

Issue simili

Altre issue su TypeScript

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.