diff --git a/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java b/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java
index 8772aa95d24727ee2f63ef627cf8f73d8dd1f473..94848489d7d5465eec7bdf064913a068c04b4318 100644
--- a/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java
+++ b/nutz-integration-jedis/src/main/java/org/nutz/integration/jedis/RedisService.java
@@ -5388,7 +5388,10 @@ public class RedisService extends Jedis {
     }
 
     public void subscribe(JedisPubSub jedisPubSub, String... channels) {
-        jedis().subscribe(jedisPubSub, channels);
+		Jedis jedis = getJedis();
+        try {
+            jedis.subscribe(jedisPubSub, channels);
+        } finally {Streams.safeClose(jedis);}
     }
 
     public Set<byte[]> zrevrangeByLex(byte[] key, byte[] max, byte[] min, int offset, int count) {