zoukankan      html  css  js  c++  java
  • pgspider redis fdw pub && sub 试用

    redis fdw 封装的redis 操作功能还是比较强大的,同时支持通过insert 的方式publish messag
    以下是一个简单的学习(但是按照原理应该也是可以sub的 (select message,细节可以看看源码))

    环境准备

    • dockerc-compose 文件
     
    version: "3"
    services: 
      redis:
        image: redis
        ports:
        - "6379:6379"
      pg-redis:
        image: dalongrong/pgspider:redis
        ports:
        - "5432:5432"
        environment: 
        - "POSTGRES_PASSWORD:dalong"

    使用

    • 启动服务
    docker-compose up -d
    • 扩展使用
    // 创建扩展
    CREATE EXTENSION redis_fdw;
    // 创建server
    CREATE SERVER redis_server 
         FOREIGN DATA WRAPPER redis_fdw 
         OPTIONS (host 'redis', port '6379');
    // 创建用户映射
    CREATE USER MAPPING FOR postgres
         SERVER redis_server
         OPTIONS (password 'demo');
    // 创建表映射
    CREATE FOREIGN TABLE rft_pub(
          channel TEXT,
          message TEXT,
          len INT
         ) SERVER redis_server
        OPTIONS (tabletype 'publish');
    • redis-cli 订阅处理
    redis-cli
    SUBSCRIBE demoapps
    • 效果
    插入数据:
    insert into rft_pub(channel,message) values('demoapp','dalong');

    说明

    redis fdw 的扩展功能还是比较强大,后边可以仔细研究下代码的实现

    参考资料

    https://github.com/nahanni/rw_redis_fdw
    https://github.com/rongfengliang/pgspider-docker
    https://hub.docker.com/repository/docker/dalongrong/pgspider

  • 相关阅读:
    B
    A
    P1057 传球游戏
    P1702 突击考试
    P1394 山上的国度
    P2117 小Z的矩阵
    P1510 精卫填海
    P1294 高手去散步
    P1071 潜伏者
    保留
  • 原文地址:https://www.cnblogs.com/rongfengliang/p/12294035.html
Copyright © 2011-2022 走看看