diff --git a/apps/jqr/pubsub.py b/apps/jqr/pubsub.py
index a0a3fe6..dec4b39 100644
--- a/apps/jqr/pubsub.py
+++ b/apps/jqr/pubsub.py
@@ -14,7 +14,7 @@ logger = logging.getLogger('apps')
 
 
 class JQREventCallbackPubSub:
-    rc = get_redis_connection()
+    rc = get_redis_connection('pubsub')
 
     @classmethod
     def publish(cls, data):
@@ -36,7 +36,7 @@ class JQREventCallbackPubSub:
 
 
 class JQREventNewUserCallbackPubSub:
-    rc = get_redis_connection()
+    rc = get_redis_connection('pubsub')
 
     @classmethod
     def publish(cls, data):
@@ -58,7 +58,7 @@ class JQREventNewUserCallbackPubSub:
 
 
 class JQRQrcodeCallbackPubSub:
-    rc = get_redis_connection()
+    rc = get_redis_connection('pubsub')
 
     @classmethod
     def publish(cls, data):
diff --git a/apps/msg/pubsub.py b/apps/msg/pubsub.py
index cfd0fc9..6ea9d5d 100644
--- a/apps/msg/pubsub.py
+++ b/apps/msg/pubsub.py
@@ -14,7 +14,7 @@ logger = logging.getLogger('apps')
 
 
 class JQRMSGPubSub:
-    rc = get_redis_connection()
+    rc = get_redis_connection('pubsub')
     msg_list = []
     BATCH_SIZE = 100
 
diff --git a/yzk_wechat_event/settings/base.py b/yzk_wechat_event/settings/base.py
index a850c3e..7bbdbb6 100644
--- a/yzk_wechat_event/settings/base.py
+++ b/yzk_wechat_event/settings/base.py
@@ -144,6 +144,15 @@ CACHES = {
             "CLIENT_CLASS": "django_redis.client.DefaultClient",
             # "PASSWORD": REDIS_PASSWORD,
         }
+    },
+    'pubsub': {
+        "BACKEND": "django_redis.cache.RedisCache",
+        "LOCATION": f"{REDIS_URI}/11",
+        "OPTIONS": {
+            "IGNORE_EXCEPTIONS": True,
+            "CLIENT_CLASS": "django_redis.client.DefaultClient",
+            # "PASSWORD": REDIS_PASSWORD,
+        }
     }
 }