diff --git a/app-stream-api/pom.xml b/app-stream-api/pom.xml
index 99fd628..b2afdde 100644
--- a/app-stream-api/pom.xml
+++ b/app-stream-api/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>open-app-stream-client</artifactId>
         <groupId>com.dingtalk.open</groupId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
diff --git a/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClient.java b/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClient.java
index d3690f2..4a593d8 100644
--- a/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClient.java
+++ b/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClient.java
@@ -14,6 +14,7 @@
 import com.dingtalk.open.app.stream.network.core.NetWorkService;
 import com.dingtalk.open.app.stream.network.core.Subscription;
 
+import java.net.Proxy;
 import java.util.Collections;
 import java.util.Set;
 import java.util.concurrent.ExecutorService;
@@ -33,23 +34,26 @@ class OpenDingTalkStreamClient implements OpenDingTalkClient {
     private OpenApiClient openApiClient;
     private Set<Subscription> subscriptions;
     private final AtomicReference<Status> status;
+    private final Proxy proxy;
 
-    public OpenDingTalkStreamClient(DingTalkCredential credential, CommandDispatcher dispatcher, ExecutorService executor, ClientOption option, Set<Subscription> subscriptions) {
+    public OpenDingTalkStreamClient(DingTalkCredential credential, CommandDispatcher dispatcher, ExecutorService executor, ClientOption option, Set<Subscription> subscriptions,
+                                    Proxy proxy) {
         this.credential = credential;
         this.dispatcher = dispatcher;
         this.executor = executor;
         this.option = option;
         this.subscriptions = Collections.unmodifiableSet(subscriptions);
         this.status = new AtomicReference<>(Status.INIT);
+        this.proxy = proxy;
     }
 
     @Override
     public synchronized void start() throws OpenDingTalkAppException {
         if (status.get() == Status.INIT) {
             this.openApiClient = OpenApiClientBuilder.create().setHost(option.getOpenApiHost()).setTimeout(option.getConnectionTTL()).build();
-            final EndPointConnectionFactory factory = () -> openConnection(this.credential, subscriptions);
+            final EndPointConnectionFactory factory = () -> openConnection(this.credential, subscriptions, proxy);
             ClientConnectionListener listener = new AppServiceListener(dispatcher, executor);
-            this.netWorkService = new NetWorkService(factory, listener, option.getMaxConnectionCount(), option.getConnectionTTL(), option.getConnectTimeout(),option.getKeepAliveOption().getKeepAliveIdleMill());
+            this.netWorkService = new NetWorkService(factory, listener, option.getMaxConnectionCount(), option.getConnectionTTL(), option.getConnectTimeout(), option.getKeepAliveOption().getKeepAliveIdleMill());
             this.netWorkService.start();
             this.status.set(Status.ACTIVE);
         } else if (status.get() == Status.INACTIVE) {
@@ -70,7 +74,7 @@ public synchronized void stop() throws Exception {
         }
     }
 
-    private EndPointConnection openConnection(DingTalkCredential credential, Set<Subscription> subscriptions) throws Exception {
+    private EndPointConnection openConnection(DingTalkCredential credential, Set<Subscription> subscriptions, Proxy proxy) throws Exception {
         OpenConnectionRequest request = new OpenConnectionRequest();
         request.setClientId(credential.getClientId());
         request.setClientSecret(credential.getClientSecret());
@@ -78,7 +82,7 @@ private EndPointConnection openConnection(DingTalkCredential credential, Set<Sub
         request.setSubscriptions(subscriptions);
         request.setLocalIp(IpUtils.getLocalIP());
         OpenConnectionResponse response = openApiClient.openConnection(request);
-        return new EndPointConnection(credential.getClientId(), response.getEndpoint(), response.getTicket());
+        return new EndPointConnection(credential.getClientId(), response.getEndpoint(), response.getTicket(), proxy);
     }
 
 
diff --git a/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClientBuilder.java b/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClientBuilder.java
index 13ea84f..44c0c1c 100644
--- a/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClientBuilder.java
+++ b/app-stream-api/src/main/java/com/dingtalk/open/app/api/OpenDingTalkStreamClientBuilder.java
@@ -1,16 +1,22 @@
 package com.dingtalk.open.app.api;
 
-import com.dingtalk.open.app.api.command.CommandDispatcher;
-import com.dingtalk.open.app.api.util.ThreadUtil;
 import com.dingtalk.open.app.api.callback.CallbackCommandExecutor;
 import com.dingtalk.open.app.api.callback.OpenDingTalkCallbackListener;
+import com.dingtalk.open.app.api.command.CommandDispatcher;
 import com.dingtalk.open.app.api.protocol.CommandExecutor;
 import com.dingtalk.open.app.api.protocol.EventCommandExecutor;
 import com.dingtalk.open.app.api.security.DingTalkCredential;
+import com.dingtalk.open.app.api.util.ThreadUtil;
+import com.dingtalk.open.app.stream.network.api.NetProxy;
 import com.dingtalk.open.app.stream.network.core.Subscription;
 import com.dingtalk.open.app.stream.protocol.CommandType;
 
-import java.util.*;
+import java.net.InetSocketAddress;
+import java.net.Proxy;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.ExecutorService;
 
 /**
@@ -27,6 +33,8 @@ public class OpenDingTalkStreamClientBuilder {
     private int connectionTimeToLive = 6 * 60 * 60 * 1000;
     private long connectTimeout = 3 * 1000L;
 
+    private Proxy proxy;
+
     private KeepAliveOption keepAliveOption = new KeepAliveOption();
 
     private String openApiHost = "https://api.dingtalk.com";
@@ -99,6 +107,17 @@ public OpenDingTalkStreamClientBuilder preEnv() {
         return this.openApiHost("https://pre-api.dingtalk.com");
     }
 
+    /**
+     * 设置代理方式
+     *
+     * @param netProxy
+     * @return
+     */
+    public OpenDingTalkStreamClientBuilder proxy(NetProxy netProxy) {
+        this.proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(netProxy.getIp(), netProxy.getPort()));
+        return this;
+    }
+
     public OpenDingTalkClient build() {
         ClientOption option = new ClientOption();
         option.setConnectTimeout(connectTimeout);
@@ -107,7 +126,7 @@ public OpenDingTalkClient build() {
         option.setOpenApiHost(openApiHost);
         option.setKeepAliveOption(keepAliveOption);
         ExecutorService executor = ThreadUtil.newFixedExecutor(consumeThreads, "DingTalk-Consumer");
-        return new OpenDingTalkStreamClient(credential, new CommandDispatcher(commands), executor, option, subscriptions);
+        return new OpenDingTalkStreamClient(credential, new CommandDispatcher(commands), executor, option, subscriptions, proxy);
     }
 
     private void subscribe(CommandType type, String topic) {
diff --git a/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/HttpOpenApiClient.java b/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/HttpOpenApiClient.java
index bf51337..db378a2 100644
--- a/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/HttpOpenApiClient.java
+++ b/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/HttpOpenApiClient.java
@@ -7,6 +7,7 @@
 import com.dingtalk.open.app.api.util.IoUtils;
 
 import java.net.HttpURLConnection;
+import java.net.Proxy;
 import java.net.URL;
 
 /**
@@ -17,16 +18,26 @@ class HttpOpenApiClient implements OpenApiClient {
 
     private final String host;
 
+    private final Proxy proxy;
+
     private final int timeout;
 
-    public HttpOpenApiClient(String host, int timeout) {
+    public HttpOpenApiClient(String host, int timeout, Proxy proxy) {
         this.host = host;
         this.timeout = timeout;
+        this.proxy = proxy;
     }
 
     @Override
     public OpenConnectionResponse openConnection(OpenConnectionRequest request) throws Exception {
-        final HttpURLConnection connection = (HttpURLConnection) new URL(host + "/v1.0/gateway/connections/open").openConnection();
+        URL url =  new URL(host + "/v1.0/gateway/connections/open");
+
+        HttpURLConnection connection;
+        if (proxy != null) {
+            connection = (HttpURLConnection) url.openConnection(proxy);
+        } else {
+            connection = (HttpURLConnection) url.openConnection();
+        }
         connection.setRequestMethod(HttpConstants.METHOD_POST);
         connection.setReadTimeout(this.timeout);
         connection.setConnectTimeout(this.timeout);
diff --git a/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/OpenApiClientBuilder.java b/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/OpenApiClientBuilder.java
index 2075ae9..8c4d678 100644
--- a/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/OpenApiClientBuilder.java
+++ b/app-stream-api/src/main/java/com/dingtalk/open/app/api/open/OpenApiClientBuilder.java
@@ -1,5 +1,7 @@
 package com.dingtalk.open.app.api.open;
 
+import java.net.Proxy;
+
 /**
  * @author feiyin
  * @date 2023/3/1
@@ -16,6 +18,8 @@ public static OpenApiClientBuilder create() {
 
     public String host;
 
+    private Proxy proxy;
+
     private int timeout = 3000;
 
     public OpenApiClientBuilder setHost(String host) {
@@ -28,7 +32,12 @@ public OpenApiClientBuilder setTimeout(int timeout) {
         return this;
     }
 
+    public OpenApiClientBuilder setProxy(Proxy proxy) {
+        this.proxy = proxy;
+        return this;
+    }
+
     public OpenApiClient build() {
-        return new HttpOpenApiClient(host, timeout);
+        return new HttpOpenApiClient(host, timeout, proxy);
     }
 }
diff --git a/app-stream-api/src/main/java/com/dingtalk/open/app/api/protocol/AppServiceListener.java b/app-stream-api/src/main/java/com/dingtalk/open/app/api/protocol/AppServiceListener.java
index 3806746..66cb718 100644
--- a/app-stream-api/src/main/java/com/dingtalk/open/app/api/protocol/AppServiceListener.java
+++ b/app-stream-api/src/main/java/com/dingtalk/open/app/api/protocol/AppServiceListener.java
@@ -29,7 +29,7 @@ public void receive(Context context) {
             try {
                 commandDispatcher.execute(context);
             } catch (Exception e) {
-                LOGGER.error("[DingTalk] dispatch command failed", e);
+                LOGGER.error("[DingTalk] dispatch command failed, {}", e);
             }
         });
     }
diff --git a/app-stream-client/pom.xml b/app-stream-client/pom.xml
index d070c74..94d79e0 100644
--- a/app-stream-client/pom.xml
+++ b/app-stream-client/pom.xml
@@ -4,13 +4,13 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>app-stream-client</artifactId>
     <packaging>jar</packaging>
-    <version>1.2.0</version>
+    <version>1.2.1</version>
     <name>app-stream-client</name>
 
     <dependencies>
diff --git a/app-stream-network/app-stream-network-api/pom.xml b/app-stream-network/app-stream-network-api/pom.xml
index ecda205..3b596dd 100644
--- a/app-stream-network/app-stream-network-api/pom.xml
+++ b/app-stream-network/app-stream-network-api/pom.xml
@@ -4,12 +4,12 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>app-stream-network-api</artifactId>
-    <version>1.2.0</version>
+    <version>1.2.1</version>
     <packaging>jar</packaging>
 
     <name>app-stream-network-api</name>
diff --git a/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/EndPointConnection.java b/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/EndPointConnection.java
index 39551a1..bcf2f5f 100644
--- a/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/EndPointConnection.java
+++ b/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/EndPointConnection.java
@@ -1,5 +1,6 @@
 package com.dingtalk.open.app.stream.network.api;
 
+import java.net.Proxy;
 import java.net.URI;
 import java.net.URISyntaxException;
 
@@ -12,7 +13,9 @@ public class EndPointConnection {
     private final URI endPoint;
     private final String connectionId;
 
-    public EndPointConnection(String clientId, String endPoint, String connectionId) {
+    private final Proxy proxy;
+
+    public EndPointConnection(String clientId, String endPoint, String connectionId, Proxy proxy) {
         this.clientId = clientId;
         try {
             this.endPoint = new URI(endPoint);
@@ -20,6 +23,7 @@ public EndPointConnection(String clientId, String endPoint, String connectionId)
             throw new RuntimeException(e);
         }
         this.connectionId = connectionId;
+        this.proxy = proxy;
     }
 
     public URI getEndPoint() {
@@ -38,4 +42,7 @@ public TransportProtocol getProtocol() {
         return TransportProtocol.parseScheme(endPoint.getScheme());
     }
 
+    public Proxy getProxy() {
+        return proxy;
+    }
 }
diff --git a/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/NetProxy.java b/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/NetProxy.java
new file mode 100644
index 0000000..c31d761
--- /dev/null
+++ b/app-stream-network/app-stream-network-api/src/main/java/com/dingtalk/open/app/stream/network/api/NetProxy.java
@@ -0,0 +1,23 @@
+package com.dingtalk.open.app.stream.network.api;
+
+/**
+ * @author feiyin
+ * @date 2023/11/21
+ */
+public class NetProxy {
+    private String host;
+    private Integer port;
+
+    public NetProxy(String host, Integer port) {
+        this.host = host;
+        this.port = port;
+    }
+
+    public String getIp() {
+        return host;
+    }
+
+    public Integer getPort() {
+        return port;
+    }
+}
diff --git a/app-stream-network/app-stream-network-core/pom.xml b/app-stream-network/app-stream-network-core/pom.xml
index 89fbb0d..2d3ce02 100644
--- a/app-stream-network/app-stream-network-core/pom.xml
+++ b/app-stream-network/app-stream-network-core/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
diff --git a/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/Connector.java b/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/Connector.java
index a48658a..847ab96 100644
--- a/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/Connector.java
+++ b/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/Connector.java
@@ -69,7 +69,7 @@ private static void ensureActive() {
             }
             INIT = true;
         } catch (Exception e) {
-            LOGGER.error("[DingTalk] client init transport failed", e);
+            LOGGER.error("[DingTalk] client init transport failed, {}", e);
         } finally {
             INIT_LOCK.unlock();
         }
diff --git a/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/DefaultSessionPool.java b/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/DefaultSessionPool.java
index 126d950..d3e4669 100644
--- a/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/DefaultSessionPool.java
+++ b/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/DefaultSessionPool.java
@@ -177,7 +177,7 @@ public void run() {
                     }
                 }
             } catch (Throwable e) {
-                LOGGER.error("[DingTalk] establish connection failed", e);
+                LOGGER.error("[DingTalk] establish connection failed, {}", e);
             }
         }
     }
@@ -201,7 +201,7 @@ public T run(Callable<T> callable) throws Exception {
                 try {
                     return callable.call();
                 } catch (Exception e) {
-                    LOGGER.error("[DingTalk] retrievable executor execute failed", e);
+                    LOGGER.error("[DingTalk] retrievable executor execute failed, {}", e);
                     if (count.get() <= 0) {
                         throw e;
                     }
diff --git a/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/NetWorkService.java b/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/NetWorkService.java
index c1175c8..549cac9 100644
--- a/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/NetWorkService.java
+++ b/app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/NetWorkService.java
@@ -1,8 +1,9 @@
 package com.dingtalk.open.app.stream.network.core;
 
 import com.dingtalk.open.app.stream.network.api.ClientConnectionListener;
-import com.dingtalk.open.app.stream.network.api.logger.InternalLogger;
-import com.dingtalk.open.app.stream.network.api.logger.InternalLoggerFactory;
+
+import java.net.Proxy;
+
 
 /**
  * @author feiyin
@@ -11,14 +12,10 @@
 public class NetWorkService {
     private final DefaultSessionPool sessionPool;
 
-    public NetWorkService(EndPointConnectionFactory factory,
-                          ClientConnectionListener listener,
-                          int maxConnection,
-                          long ttl,
-                          long connectTimeout,
-                          long keepAliveIdle) {
+    public NetWorkService(EndPointConnectionFactory factory, ClientConnectionListener listener, int maxConnection, long ttl, long connectTimeout, long keepAliveIdle) {
         this.sessionPool = new DefaultSessionPool(factory, maxConnection, ttl, connectTimeout, keepAliveIdle, listener);
     }
+
     /**
      * 开始
      */
diff --git a/app-stream-network/app-stream-network-rsocket/pom.xml b/app-stream-network/app-stream-network-rsocket/pom.xml
index 465aa81..2dd72bb 100644
--- a/app-stream-network/app-stream-network-rsocket/pom.xml
+++ b/app-stream-network/app-stream-network-rsocket/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
diff --git a/app-stream-network/app-stream-network-ws/pom.xml b/app-stream-network/app-stream-network-ws/pom.xml
index fac5b3d..1f10097 100644
--- a/app-stream-network/app-stream-network-ws/pom.xml
+++ b/app-stream-network/app-stream-network-ws/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
@@ -26,5 +26,9 @@
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-handler-proxy</artifactId>
+        </dependency>
     </dependencies>
 </project>
diff --git a/app-stream-network/app-stream-network-ws/src/main/java/com/dingtalk/open/app/stream/network/ws/WebsocketTransportConnector.java b/app-stream-network/app-stream-network-ws/src/main/java/com/dingtalk/open/app/stream/network/ws/WebsocketTransportConnector.java
index 04d969a..cfd6c97 100644
--- a/app-stream-network/app-stream-network-ws/src/main/java/com/dingtalk/open/app/stream/network/ws/WebsocketTransportConnector.java
+++ b/app-stream-network/app-stream-network-ws/src/main/java/com/dingtalk/open/app/stream/network/ws/WebsocketTransportConnector.java
@@ -12,6 +12,7 @@
 import io.netty.handler.codec.http.HttpObjectAggregator;
 import io.netty.handler.codec.http.websocketx.WebSocketClientProtocolConfig;
 import io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler;
+import io.netty.handler.proxy.HttpProxyHandler;
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.SslHandler;
@@ -31,6 +32,7 @@
 @Protocol(protocol = {TransportProtocol.WSS})
 public class WebsocketTransportConnector implements TransportConnector {
     private static final InternalLogger LOGGER = InternalLoggerFactory.getLogger(WebsocketTransportConnector.class);
+
     @Override
     public Session connect(EndPointConnection connection, ClientConnectionListener listener, ConnectOption option) throws Exception {
         LOGGER.info("[DingTalk] start websocket connection, uri={}", connection.getEndPoint().toString());
@@ -41,12 +43,10 @@ public Session connect(EndPointConnection connection, ClientConnectionListener l
         bootstrap.handler(new ChannelInitializer<SocketChannel>() {
             @Override
             protected void initChannel(SocketChannel socketChannel) throws Exception {
-                WebSocketClientProtocolConfig config = WebSocketClientProtocolConfig.newBuilder().dropPongFrames(false)
-                        .webSocketUri(configureWebsocketUri(connection))
-                        .handshakeTimeoutMillis(option.getTtl())
-                        .dropPongFrames(false)
-                        .handleCloseFrames(true)
-                        .build();
+                if (connection.getProxy() != null) {
+                    socketChannel.pipeline().addLast(new HttpProxyHandler(connection.getProxy().address()));
+                }
+                WebSocketClientProtocolConfig config = WebSocketClientProtocolConfig.newBuilder().dropPongFrames(false).webSocketUri(configureWebsocketUri(connection)).handshakeTimeoutMillis(option.getTtl()).dropPongFrames(false).handleCloseFrames(true).build();
                 SslContext sslContext = SslContextBuilder.forClient().build();
                 if (connection.getProtocol().isTls()) {
                     final SSLEngine engine = sslContext.newEngine(socketChannel.alloc());
diff --git a/app-stream-network/pom.xml b/app-stream-network/pom.xml
index 7f72e23..0361fc6 100644
--- a/app-stream-network/pom.xml
+++ b/app-stream-network/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>open-app-stream-client</artifactId>
         <groupId>com.dingtalk.open</groupId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <packaging>pom</packaging>
diff --git a/app-stream-protocol/pom.xml b/app-stream-protocol/pom.xml
index 2b2e3c4..1306145 100644
--- a/app-stream-protocol/pom.xml
+++ b/app-stream-protocol/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
     </parent>
 
     <artifactId>app-stream-protocol</artifactId>
diff --git a/dingtalk-stream/pom.xml b/dingtalk-stream/pom.xml
index 1d499ad..4734336 100644
--- a/dingtalk-stream/pom.xml
+++ b/dingtalk-stream/pom.xml
@@ -4,13 +4,13 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.2.0</version>
+        <version>1.2.1</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>dingtalk-stream</artifactId>
     <packaging>jar</packaging>
-    <version>1.2.0</version>
+    <version>1.2.1</version>
     <name>app-stream-client</name>
 
     <dependencies>
diff --git a/pom.xml b/pom.xml
index 1508295..964e735 100644
--- a/pom.xml
+++ b/pom.xml
@@ -5,7 +5,7 @@
     <groupId>com.dingtalk.open</groupId>
     <artifactId>open-app-stream-client</artifactId>
     <packaging>pom</packaging>
-    <version>1.2.0</version>
+    <version>1.2.1</version>
     <modules>
         <module>app-stream-client</module>
         <module>app-stream-api</module>
@@ -69,6 +69,11 @@
                 <artifactId>netty-codec-http</artifactId>
                 <version>4.1.81.Final</version>
             </dependency>
+            <dependency>
+                <groupId>io.netty</groupId>
+                <artifactId>netty-handler-proxy</artifactId>
+                <version>4.1.81.Final</version>
+            </dependency>
             <dependency>
                 <groupId>io.netty</groupId>
                 <artifactId>netty-common</artifactId>
diff --git a/version.sh b/version.sh
index 69b1fca..011cf51 100755
--- a/version.sh
+++ b/version.sh
@@ -1,3 +1,3 @@
 #!/usr/bin/env bash
 
-mvn versions:set -DnewVersion=1.2.0
+mvn versions:set -DnewVersion=1.2.1