rs和actix-web

xqk2d5yq 于 2021-06-10 发布在 Redis

关注(0)|答案(1)|浏览(448)

我正在尝试添加redis作为 web::Data 我的actix web应用程序的上下文：

extern crate redis;

// std imports
use std::net::SocketAddr;
// external imports
use actix_web::{App, HttpServer};
use redis::Client

# [actix_rt::main]

async fn main() -> std::io::Result<()> {
    // connect to redis
    let redis_con = Client::open("redis://127.0.0.1:6379")
        .unwrap()
        .get_connection()
        .unwrap();

    HttpServer::new(move || App::new().data(redis_con).service(api::get_healthz))
        .bind(SocketAddr::new(IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)), 8080)?
        .run()
        .await
}

我得到以下错误： the trait bound 'redis::Connection: std::clone::Clone' is not satisfied in '[closure@src/main.rs:48:21: 48:81 redis_con:redis::Connection]' 我已经试着把它 Package 成 Arc<redis::Connection> 的子模块中的某些类型也不适用 redis::Connection 但没有实现 Sync .
有没有生 rust 的概念，我没有看到在这种情况下？这是我第一个真正的生 rust 项目之一，所以可能有一些我非常粗略地忽略了。

redis rust rust-actix actix-web

来源：https://stackoverflow.com/questions/62972342/using-redis-rs-with-actix-web

1条答案

按热度按时间

qacovj5a1#

这个答案是actix解决问题的一个最简单的例子。不过，实现你想要的东西可能有更短的方法。
首先需要导入 actix 机箱：

[package]
name = "test-actix-redis"
version = "0.1.0"
authors = ["Njuguna Mureithi <email@gmail.com>"]
edition = "2018"

# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
actix-web = "2.0"
actix-rt = "1.0"
redis = "0.15"
actix = "0.10.0-alpha.3"

然后定义你的演员：

use actix_web::{web, App, HttpResponse, HttpServer, Responder};
use redis::{Client, aio::MultiplexedConnection};
use actix::prelude::*;

struct RedisActor {
    conn: MultiplexedConnection,
}

impl RedisActor {
    pub async fn new(redis_url: &'static str) -> Self {
        let client = Client::open(redis_url).unwrap();// not recommended
        let (conn, call) = client.get_multiplexed_async_connection().await.unwrap();
        actix_rt::spawn(call);
        RedisActor { conn }
    }
}

# [derive(Message, Debug)]

# [rtype(result = "Result<Option<String>, redis::RedisError>")]

struct InfoCommand;

impl Handler<InfoCommand> for RedisActor {
    type Result = ResponseFuture<Result<Option<String>, redis::RedisError>>;

    fn handle(&mut self, _msg: InfoCommand, _: &mut Self::Context) -> Self::Result {
        let mut con = self.conn.clone();
        let cmd = redis::cmd("INFO");
        let fut = async move {
            cmd
                .query_async(&mut con)
                .await
        };
        Box::pin(fut)
    }
}

impl Actor for RedisActor {
    type Context = Context<Self>;
}

async fn info(redis: web::Data<Addr<RedisActor>>) -> impl Responder {
    let res = redis.send(InfoCommand).await.unwrap().unwrap().unwrap();
    HttpResponse::Ok().body(res)
}

# [actix_rt::main]

async fn main() -> std::io::Result<()> {
    let actor = RedisActor::new("redis://127.0.0.1:6379").await;
    let addr = actor.start();
    HttpServer::new(move || {
        App::new()
            .data(addr.clone())
            .route("/", web::get().to(info))
    })
    .bind("127.0.0.1:8088")?
    .run()
    .await
}

现在运行项目：

cargo run

去 http://localhost:8088/ 应该把你的redis信息作为一个字符串给你。

赞(0）回复(0）举报 2021-06-10

我来回答

rs和actix-web

1条答案

相关问题

热门标签

最新问答