From f0590812c166d4a21fc3f9569b42cc5e4c9a3ee0 Mon Sep 17 00:00:00 2001
From: richie <jihua.me@gmail.com>
Date: Wed, 6 Jun 2018 17:34:14 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A0JIRA=E4=BB=BB=E5=8A=A1=20=E8=BF=9C?=
 =?UTF-8?q?=E7=A8=8B=E8=AE=BE=E8=AE=A1=E6=94=B9=E5=96=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../fr/design/mainframe/DesignerFrame.java    |  2 +-
 designer-base/src/com/fr/env/RemoteEnv.java   | 20 +++++++++++++++++++
 2 files changed, 21 insertions(+), 1 deletion(-)

diff --git a/designer-base/src/com/fr/design/mainframe/DesignerFrame.java b/designer-base/src/com/fr/design/mainframe/DesignerFrame.java
index 828c6623b..43d3787b8 100644
--- a/designer-base/src/com/fr/design/mainframe/DesignerFrame.java
+++ b/designer-base/src/com/fr/design/mainframe/DesignerFrame.java
@@ -968,7 +968,7 @@ public class DesignerFrame extends JFrame implements JTemplateActionListener, Ta
         Env currentEnv = FRContext.getCurrentEnv();
         try {
             EventDispatcher.fire(BEFORE_SIGN_OUT);
-            currentEnv.signOut();
+            currentEnv.disconnect();
             EventDispatcher.fire(AFTER_SIGN_OUT);
         } catch (Exception e) {
             FineLoggerFactory.getLogger().error(e.getMessage(), e);
diff --git a/designer-base/src/com/fr/env/RemoteEnv.java b/designer-base/src/com/fr/env/RemoteEnv.java
index 8e17a4e22..fb52d7028 100644
--- a/designer-base/src/com/fr/env/RemoteEnv.java
+++ b/designer-base/src/com/fr/env/RemoteEnv.java
@@ -2,7 +2,10 @@ package com.fr.env;
 
 import com.fr.base.EnvException;
 import com.fr.base.TableData;
+import com.fr.base.operator.file.FileOperator;
 import com.fr.base.remote.RemoteDeziConstants;
+import com.fr.common.rpc.netty.MessageSendExecutor;
+import com.fr.common.rpc.serialize.RpcSerializeProtocol;
 import com.fr.core.env.EnvConstants;
 import com.fr.core.env.EnvContext;
 import com.fr.core.env.resource.RemoteEnvConfig;
@@ -87,6 +90,23 @@ public class RemoteEnv extends AbstractEnv implements DesignAuthorityConfigurabl
         env = new RemoteEnvConfig(path, userName, password);
     }
 
+    @Override
+    public void connect() {
+        // FIXME:richie ip地址属于测试的，带实际修改为RemoteEnv配置的地址
+        MessageSendExecutor.getInstance().setRpcServerLoader("127.0.0.1:" + 33999, RpcSerializeProtocol.KRYOSERIALIZE);
+    }
+
+    @Override
+    public boolean disconnect() {
+        MessageSendExecutor.getInstance().stop();
+        return true;
+    }
+
+    @Override
+    public FileOperator getFileOperator() throws Exception {
+        return MessageSendExecutor.getInstance().execute(FileOperator.class);
+    }
+
     @Override
     public String getPath() {
         return env.getPath();