Browse Source

无JIRA任务 远程调用服务器的各种配置写入配置库

master
richie 7 years ago
parent
commit
72d747331f
  1. 5
      designer-base/src/com/fr/env/RemoteEnv.java

5
designer-base/src/com/fr/env/RemoteEnv.java vendored

@ -4,8 +4,9 @@ import com.fr.base.EnvException;
import com.fr.base.TableData; import com.fr.base.TableData;
import com.fr.base.operator.file.FileOperator; import com.fr.base.operator.file.FileOperator;
import com.fr.base.remote.RemoteDeziConstants; import com.fr.base.remote.RemoteDeziConstants;
import com.fr.common.rpc.RemoteCallServerConfig;
import com.fr.common.rpc.netty.MessageSendExecutor; import com.fr.common.rpc.netty.MessageSendExecutor;
import com.fr.common.rpc.serialize.RpcSerializeProtocol; import com.fr.common.rpc.serialize.SerializeProtocol;
import com.fr.core.env.EnvConstants; import com.fr.core.env.EnvConstants;
import com.fr.core.env.EnvContext; import com.fr.core.env.EnvContext;
import com.fr.core.env.resource.RemoteEnvConfig; import com.fr.core.env.resource.RemoteEnvConfig;
@ -95,7 +96,7 @@ public class RemoteEnv extends AbstractEnv implements DesignAuthorityConfigurabl
@Override @Override
public void connect() { public void connect() {
// FIXME:richie ip地址属于测试的,带实际修改为RemoteEnv配置的地址 // FIXME:richie ip地址属于测试的,带实际修改为RemoteEnv配置的地址
MessageSendExecutor.getInstance().setRpcServerLoader("127.0.0.1:" + 33999, RpcSerializeProtocol.KRYOSERIALIZE); MessageSendExecutor.getInstance().setRpcServerLoader("127.0.0.1", RemoteCallServerConfig.getInstance().getPort(), RemoteCallServerConfig.getInstance().getSerializeProtocol());
} }
@Override @Override

Loading…
Cancel
Save