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