redis_kiss

注意：现在这也暴露了对Redis连接池的访问。

这是一个非常简单的库，仅用于消费和产生Redis PubSub的消息，它几乎不遵循“良好的编程实践”，但它确实可以工作并简化所需的工作。

该库管理一个全局的Redis连接池，并动态创建监听连接（由于一些技术限制）。

示例

向Redis发布内容

// Handle the Result<_, _>
redis_kiss::publish("channel", "data").await?;

// Log the error instead
redis_kiss::p("channel", "data").await;

订阅Redis（如通常情况，请参阅Redis文档以获取更多信息）

// Create a new PubSub connection
let mut conn = redis_kiss::open_pubsub_connection().await?;

// Subscribe to something
conn.subscribe("test").await?;

// Handle incoming messages
let mut stream = conn.on_message();
while let Some(item) = stream.next().await {
    // Use Redis crate API as usual
    let channel = item.get_channel_name().to_string();

    // Decode the message using previously specified options
    // into a certain DeserializeOwned data type T, in this case String
    let payload: String = redis_kiss::decode_payload(&item).await?;

    // You can also choose a specific type on the fly
    use redis_kiss::PayloadType;
    let payload: String = redis_kiss::decode_payload(&item, &PayloadType::Msgpack).await?;

    // Do something with channel and payload
}

环境变量

该库通过环境提供选项。