From 5db4f7bca12d76d231a1d0967267bfb3553cd397 Mon Sep 17 00:00:00 2001
From: fly6516 <fly6516@outlook.com>
Date: Wed, 26 Mar 2025 09:59:07 +0800
Subject: [PATCH] =?UTF-8?q?perf(hbase):=20=E4=BC=98=E5=8C=96=20HBase=20?=
 =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E9=85=8D=E7=BD=AE=E4=BB=A5=E6=8F=90?=
 =?UTF-8?q?=E9=AB=98=E8=BF=9E=E6=8E=A5=E5=8F=AF=E9=9D=A0=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 添加 ZooKeeper端口配置，确保与 ZooKeeper 正确连接
- 设置客户端重试次数和 RPC 超时时间，提升临时连接问题的容错能力
---
 src/main/java/EmpHBaseClient.java | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/main/java/EmpHBaseClient.java b/src/main/java/EmpHBaseClient.java
index bc4ca7d..1862b21 100644
--- a/src/main/java/EmpHBaseClient.java
+++ b/src/main/java/EmpHBaseClient.java
@@ -39,6 +39,12 @@ public class EmpHBaseClient {
     public EmpHBaseClient() {
         conf = HBaseConfiguration.create();
         conf.set("hbase.zookeeper.quorum", "localhost");
+        // 新增ZooKeeper端口配置（默认2181但显式声明更可靠）
+        conf.set("hbase.zookeeper.property.clientPort", "2181");
+        // 新增重试策略配置（解决临时连接问题）
+        conf.set("hbase.client.retries.number", "3");
+        conf.set("hbase.rpc.timeout", "60000");
+        
         try {
             connection = ConnectionFactory.createConnection(conf);
             table = connection.getTable(TableName.valueOf("emp1520"));