This commit is contained in:
SpringHgui 2020-03-31 16:51:28 +08:00
parent b340f76b49
commit 61324186db
2 changed files with 4 additions and 4 deletions

View File

@ -120,7 +120,7 @@ namespace FastTunnel.Core.Client
//连接到的目标IP
try
{
_client = new Connecter(_clientConfig.Common.ServerAddr, _clientConfig.Common.ServerPort);
_client = new Connecter(_clientConfig.Common.ip, _clientConfig.Common.bind_port);
_client.Connect();
}
catch (Exception ex)
@ -217,7 +217,7 @@ namespace FastTunnel.Core.Client
break;
case MessageType.S_NewCustomer:
var request = (Msg.Content as JObject).ToObject<NewCustomerRequest>();
var connecter = new Connecter(_clientConfig.Common.ServerAddr, _clientConfig.Common.ServerPort);
var connecter = new Connecter(_clientConfig.Common.ip, _clientConfig.Common.bind_port);
connecter.Connect();
connecter.Send(new Message<string> { MessageType = MessageType.C_SwapMsg, Content = request.MsgId });
@ -228,7 +228,7 @@ namespace FastTunnel.Core.Client
break;
case MessageType.S_NewSSH:
var request_ssh = (Msg.Content as JObject).ToObject<NewSSHRequest>();
var connecter_ssh = new Connecter(_clientConfig.Common.ServerAddr, _clientConfig.Common.ServerPort);
var connecter_ssh = new Connecter(_clientConfig.Common.ip, _clientConfig.Common.bind_port);
connecter_ssh.Connect();
connecter_ssh.Send(new Message<string> { MessageType = MessageType.C_SwapMsg, Content = request_ssh.MsgId });

View File

@ -316,7 +316,7 @@ namespace FastTunnel.Core.Server
SSHList.Add(item.RemotePort, new SSHInfo<SSHHandlerArg> { Listener = ls, Socket = client, SSHConfig = item });
_logger.LogDebug($"SSH proxy success: {item.RemotePort} -> {item.LocalIp}:{item.LocalPort}");
client.Send(new Message<string> { MessageType = MessageType.Info, Content = $"TunnelForSSH is OK: {requet.ClientConfig.Common.ServerAddr}:{item.RemotePort}->{item.LocalIp}:{item.LocalPort}" });
client.Send(new Message<string> { MessageType = MessageType.Info, Content = $"TunnelForSSH is OK: {requet.ClientConfig.Common.ip}:{item.RemotePort}->{item.LocalIp}:{item.LocalPort}" });
}
catch (Exception ex)
{