camellia redis proxy v1.3.3对redis主从进行读写分离（非写死，自动识别故障转移）

1 概述

camellia-redis-proxy是一款高性能的redis代理（https://github.com/netease-im/camellia），使用netty4开发，主要特性如下：

支持代理到redis-standalone、redis-sentinel、redis-cluster。
支持其他proxy作为后端（如双写迁移场景），如 twemproxy 、codis 等。
支持 kvrocks 、 pika 、 tendis 等作为后端。
支持自定义分片。
支持读写分离。
支持双（多）写，可以proxy直连双写，也可以基于mq（如kafka）双写，也可以基于插件体系自定义双写规则。
支持多租户，即租户A路由到redis1，租户B路由到redis2（可以通过不同的clientname区分，也可以通过不同的password区分）。
支持多租户动态路由，支持自定义的动态路由数据源(内置：本地配置文件、nacos、etcd等，也可以自定义)。
支持自定义插件，并且内置了很多插件，可以按需使用（包括：大key监控、热key监控、热key缓存、key命名空间、ip黑白名单、速率控制等等）。
支持丰富的监控，可以监控客户端连接数、调用量、方法耗时、大key、热key、后端redis连接数和耗时等，并且支持以http接口形式获取监控数据。
等等其他优点。

本文介绍camellia-redis-proxy为哨兵模式部署的redis主从实例进行能读写分离，是能识别redis故障转移的读写分离。

2 部署redis一主两从

cd /tmp
helm pull --untar stable/redis-ha
helm install myredis -n default --set hardAntiAffinity=false ./redis-ha

在这里插入图片描述

3 部署camellia redis proxy

将如下三个文件apply到k8s集群即可。

apiVersion: apps/v1
kind: Deployment
metadata:name: deploy-db-camellia-testlabels:app: pod-db-camellia-test
spec:replicas: 1selector:matchLabels:app: pod-db-camellia-testtemplate:metadata:labels:app: pod-db-camellia-testspec:enableServiceLinks: falsecontainers:- name: container-camelliaimage: swr.cn-south-1.myhuaweicloud.com/migrator/camellia-redis-proxy:1.3.3command:- java- "-XX:+UseG1GC"- "-XX:+UseContainerSupport"- "-Dio.netty.tryReflectionSetAccessible=true" - "--add-opens"- "java.base/java.lang=ALL-UNNAMED" - "--add-opens"- "java.base/java.io=ALL-UNNAMED" - "--add-opens"- "java.base/java.math=ALL-UNNAMED" - "--add-opens"- "java.base/java.net=ALL-UNNAMED" - "--add-opens"- "java.base/java.nio=ALL-UNNAMED" - "--add-opens"- "java.base/java.security=ALL-UNNAMED" - "--add-opens"- "java.base/java.text=ALL-UNNAMED" - "--add-opens"- "java.base/java.time=ALL-UNNAMED" - "--add-opens"- "java.base/java.util=ALL-UNNAMED" - "--add-opens"- "java.base/jdk.internal.access=ALL-UNNAMED" - "--add-opens"- "java.base/jdk.internal.misc=ALL-UNNAMED" - "--add-opens"- "java.base/sun.net.util=ALL-UNNAMED"- "-Xms100m"- "-Xmx4096m"- "-server"- "org.springframework.boot.loader.JarLauncher"resources:requests:memory: "100Mi"cpu: "1"limits:memory: "4Gi"cpu: "1"ports:- containerPort: 6380name: dbprotocol: TCPvolumeMounts:- name: cm-db-camellia-testmountPath: /opt/camellia-redis-proxy/BOOT-INF/classes/application.ymlsubPath: application-sentinel-singlewrite-multiread.yml- name: cm-db-camellia-testmountPath: /opt/camellia-redis-proxy/BOOT-INF/classes/resource-sentinel-singlewrite-multiread.jsonsubPath: resource-sentinel-singlewrite-multiread.jsonvolumes:- name: cm-db-camellia-testconfigMap:name: cm-db-camellia-test

apiVersion: v1
kind: ConfigMap
metadata:name: cm-db-camellia-test
data:application-sentinel-singlewrite-multiread.yml: |server:port: 6380spring:application:name: camellia-redis-proxy-servercamellia-redis-proxy:console-port: 16379password: pass123 monitor-enable: false  monitor-interval-seconds: 60plugins: #plugin list- monitorPlugin- bigKeyPlugin- hotKeyPluginconfig:"check.redis.resource.valid.not.active.threshold.sceonds": 300 transpond:type: local local:type: complexjson-file: resource-sentinel-singlewrite-multiread.jsonredis-conf:preheat: falseclose-idle-connection: truecheck-idle-connection-threshold-seconds: 600close-idle-connection-delay-seconds: 60resource-sentinel-singlewrite-multiread.json: |{"type": "simple","operation": {"read": "redis-sentinel-slaves://@myredis-redis-ha-announce-0:26379/mymaster?withMaster=false","type": "rw_separate","write": "redis-sentinel://@myredis-redis-ha-announce-1:26379/mymaster"}}

apiVersion: v1
kind: Service
metadata:annotations:prometheus.io/path: /metricsprometheus.io/port: "16379"prometheus.io/scrape: "true"prometheus.io/scrape_slow: "true"prometheus.io/services: "false"name: svc-db-camellia-testnamespace: default
spec:ports:- name: port-6380port: 6380protocol: TCPtargetPort: 6380- name: port-16379port: 16379protocol: TCPtargetPort: 16379selector:app: pod-db-camellia-testsessionAffinity: Nonetype: ClusterIP