From 597b69f50b83975f475372ccbe398da94a6a9853 Mon Sep 17 00:00:00 2001
From: ping403 <jincheng9063@sina.com>
Date: Thu, 4 Nov 2021 14:55:49 +0800
Subject: [PATCH] fix: add sotimeout

---
 .../shyiko/mysql/binlog/network/DefaultSSLSocketFactory.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/github/shyiko/mysql/binlog/network/DefaultSSLSocketFactory.java b/src/main/java/com/github/shyiko/mysql/binlog/network/DefaultSSLSocketFactory.java
index 388e95d..e358ec7 100644
--- a/src/main/java/com/github/shyiko/mysql/binlog/network/DefaultSSLSocketFactory.java
+++ b/src/main/java/com/github/shyiko/mysql/binlog/network/DefaultSSLSocketFactory.java
@@ -50,8 +50,10 @@ public SSLSocket createSocket(Socket socket) throws SocketException {
             throw new SocketException(e.getMessage());
         }
         try {
-            return (SSLSocket) sc.getSocketFactory()
+            SSLSocket sslSocket = (SSLSocket) sc.getSocketFactory()
                 .createSocket(socket, socket.getInetAddress().getHostName(), socket.getPort(), true);
+            sslSocket.setSoTimeout(5 * 60 * 1000);
+            return sslSocket;
         } catch (IOException e) {
             throw new SocketException(e.getMessage());
         }