redis - 通过 phoenix channel 从 redis channel 流式传输

In lại 作者：IT王子 更新时间：2023-10-29 06:04:25 25 4

defmodule MyApp.ChannelName do
  use Phoenix.Channel

  def join(stream_name, _message, socket) do
    # Open a link to the redis server
    {:ok, pubsub} = Redix.PubSub.start_link()

    # Subscribe to the users stream
    Redix.PubSub.subscribe(pubsub, stream_name, self())

    {:ok, socket}
  kết thúc

  # Avoid throwing an error when a subscribed message enters the channel
  def handle_info({:redix_pubsub, redix_pid, :subscribed, _}, socket) do
    {:noreply, socket}
  kết thúc

  # Handle the message coming from the Redis PubSub channel
  def handle_info({:redix_pubsub, redix_pid, :message, %{channel: channel, payload: message}}, socket) do
    # Push the message back to the user
    push socket, "#{channel}", %{message: message}
    {:noreply, socket}
  kết thúc
kết thúc

25 4 0

• redis - Cách nhận thông báo xuất bản Redis khi máy chủ Redis gặp sự cố

  Tôi có một bài tập về Redis Pubsub như sau: Nếu nhà xuất bản xuất bản một tin nhắn nhưng người đăng ký không nhận được thì máy chủ gặp sự cố. Làm thế nào để người đăng ký nhận được thông báo này khi máy chủ được khởi động lại? Xin hãy giúp tôi, cảm ơn bạn! Câu trả lời hay nhất Trong trường hợp này tin nhắn sẽ biến mất vĩnh viễn

• redis - Ngăn xếp dịch vụ Redis kết nối lại sau khi khởi động lại máy chủ Redis

  Chúng tôi đang sử dụng BlockingDequeue của RedisClient của Service Stack để giữ một số dữ liệu cho đến khi nó có thể được xử lý. Mã gọi trông giống như sử dụng (var client =

• redis - Làm cách nào để khiến một khách hàng Redis đợi tất cả các khách hàng Redis khác phản hồi?

  Tôi có một máy chủ Redis và nhiều máy khách Redis. Mỗi máy khách Redis là một máy chủ WebSocket+HTTP, bao gồm cả việc quản lý các kết nối WebSocket. ThisWebSocket+HTT

• redis - Di chuyển dữ liệu từ phiên bản độc lập của Redis sang cụm Redis

  Tôi có nhiều phiên bản Redis. Tôi đã tạo một cụm bằng các cổng khác nhau. Bây giờ tôi muốn chuyển dữ liệu từ phiên bản redis có sẵn sang cụm. Tôi biết cách chuyển dữ liệu từ một phiên bản sang cụm nhưng tôi không thể thực hiện việc đó khi có nhiều hơn một phiên bản. tối ưu

• redis - Tự động chuyển đổi dự phòng sang Redis Slave được quảng bá bằng Redis Cluster

  Cấu hình: ba phân vùng cụm redis, trải rộng trên ba nhóm, một chính và một phụ. Khi Master đi xuống, Lettuce sẽ ngay lập tức phát hiện sự gián đoạn và bắt đầu thử lại. Tuy nhiên, Lettuce không phát hiện ra rằng người nô lệ liên quan đã thăng chức cho mình thành chủ nhân.

• redis - Làm cách nào để xóa khóa Redis được lưu trữ trong bộ Redis nhất định?

  Tôi muốn xóa khóa Redis (và bộ dữ liệu của chúng) dựa trên việc truy xuất các khóa này từ một bộ sưu tập được chỉ định, ví dụ: HMSET id:1 mật khẩu 123 danh mục sữa HMSET id:2 mật khẩu 456

• redis - Có cách nào để lấy danh sách tất cả các lệnh redis bị vô hiệu hóa từ redis không?

  Tôi đang viết một bot (có danh sách các lệnh cần tắt) để giám sát Redis. Nó vô hiệu hóa lệnh bằng cách thực thi nó như (rename-command ZADD "") Khi tôi khởi động lại bot của mình, nếu danh sách các lệnh bị vô hiệu hóa thay đổi

• redis - Redis (redis-py) có thể xử lý bao nhiêu kênh?

  Tôi được giao nhiệm vụ sử dụng xuất bản/đăng ký cho một lượng lớn khán giả. Đây là một ví dụ đơn giản về đăng ký từ các tài liệu: r = redis.StrictRedis(...) p = r.pubsub() p.subscribe('my-firs

• redis - 1 Redis Sentinel và nhiều Redis Sentinel?

  Tôi đã đọc về cách sử dụng Redis Sentinel để chuyển đổi dự phòng. Mình dự định có 1 master + 1 Slave nếu master down lâu hơn 1 phút thì Slave sẽ trở thành master. Tôi biết điều này ở Sentinel là

• redis - phân chia cụm Redis và Redis thông thường

  Ưu điểm của việc sử dụng Redis Cluster so với việc chỉ sử dụng Redis thông thường và tạo phân đoạn là gì? Theo tôi, Redis Cluster chú trọng hơn đến vấn đề bảo mật dữ liệu (để kiến ​​trúc master-slave giải quyết các lỗi). Câu trả lời hay nhất tôi nghĩ khi bạn cần làm điều này mà không mất bất kỳ dữ liệu nào

• redis - Có thể lấy khóa Redis ngay cả khi nó đã hết hạn (nhưng vẫn tồn tại trong Redis) không?

  Vì Redis hết hạn khóa theo cả cách thụ động và chủ động, nên có cách nào để lấy khóa ngay cả khi thời gian hết hạn đã qua (nhưng vẫn tồn tại trong Redis) không? Câu trả lời hay nhất ĐỐI TƯỢNG GỠ LỖI myKey sẽ quay trở lại

• redis - Cách chạy lệnh giám sát redis thay vì giám sát redis-cli trong tập lệnh redis lua

  Tôi muốn sử dụng redis lua để thực hiện lệnh giám sát thay vì màn hình redis-cli. Nhưng tôi không biết phải làm gì. redis.call('monitor') không hoạt động. Câu trả lời hay nhất Bạn không thể đọc từ Redis

• redis - Sự khác biệt giữa :Redis Replicad setup, Redis Cluster setup, Redis Sentinel setup và Redis with Master with Slave only là gì? [ĐỔI LẠI]

  Tôi đã đọc https://github.com/redisson/redisson và thấy rằng có một số thiết lập sao chép Redis (bao gồm hỗ trợ cho AWS ElastiCache và Azure Redis Cache)

• redis - Microsoft.AspNet.SignalR.Redis yêu cầu StackExchange.Redis.StrongName, nhưng StackExchange.Redis.Extensions.Core yêu cầu StackExchange.Redis

  Microsoft.AspNet.SignalR.Redis và StackExchange.Redis.Extensions.Core được sử dụng trong cùng một dự án. Cái trước yêu cầu StackExchange.Red

• [Redis] Quá trình cài đặt, khởi động và sử dụng Redis

  1. Làm quen với máy chủ từ điển từ xa Redis Redis (Máy chủ Từ điển Từ xa) là một cơ sở dữ liệu NoSQL dựa trên cặp khóa-giá trị dựa trên bộ nhớ. Các tính năng: loại khóa-giá trị, giá trị

• [Redis] Giới thiệu cấu trúc dữ liệu Redis

  1. Giới thiệu về cấu trúc dữ liệu Redis Redis là một cơ sở dữ liệu khóa-giá trị. Khóa nói chung là loại Chuỗi, nhưng có nhiều loại giá trị khác nhau Dưới đây là một số ví dụ: Ví dụ về loại giá trị Str.

• [Redis] Mẹo sử dụng bộ đệm Redis (bộ đệm truy vấn của người bán)

  1. Cache là gì? Cache là bộ đệm để trao đổi dữ liệu. Nói chung, nó có hiệu suất đọc và ghi cao. Vai trò của bộ đệm: Giảm tải phía sau, cải thiện hiệu quả đọc và ghi và giảm thời gian phản hồi: Chi phí nhất quán dữ liệu, Chi phí bảo trì mã.

• redis - redis: chèn hàng loạt bằng joblib

  Tôi có một danh sách các hồ sơ. Đối với mỗi bản ghi của mình, tôi cần thực hiện một số phép tính nặng nề vì tôi đang tạo chỉ mục đảo ngược trong Redis. Để đạt được bản ghi đến, nhiều lệnh redis cần được thực thi trong đường ống (sadd là 100 s + set là 1

• redis - Redis Multi Sentinel không chọn máy chủ Redis mới sau khi thất bại

  Tôi có Redis 3 nút và Sentinel 3 nút, mọi thứ đều hoạt động tốt, tất cả các nút chính và phụ đều được xác minh và các tệp cấu hình trọng điểm được cập nhật với tất cả các nút redis và trọng điểm, nhưng vấn đề là khi redis master không hoạt động và trọng điểm muốn bầu lại kẻ thua cuộc

• Redis: Làm cách nào để tính chênh lệch thời gian trong chuỗi thời gian danh sách được sắp xếp?

  Tôi đang cố tính thời gian phản hồi giữa các tin nhắn được lưu trữ trong Redis. Nhưng tôi không biết làm thế nào để làm điều đó. Trước tiên, tôi phải lưu trữ luồng thời gian của tin nhắn trò chuyện như cuộc trò chuyện ZADD này:CONVERSATION_ID