2016-03-10 5 views
0

Я создал два проекта один с клиентом и другим с сервером для обмена текстом между ними обоими, на одном компьютере я запускаю эти exe. MY стороне клиента подключения Код подключения посмотрел:Соединение с клиентом и сервером с использованием C#

using (SocketClient sa = new SocketClient(host, port)) 
    { 
    sa.Connect(); 
    Console.WriteLine(sa.SendReceive("Message #" + i.ToString())); 
    } 
    sa.Disconnect();  

в то время как socketclient мой класс, который содержит эти методы и конструктор:

internal SocketClient(String hostName, Int32 port) 
{ 
IPHostEntry host = Dns.GetHostEntry(hostName);  
IPAddress[] addressList = host.AddressList;  
this.hostEndPoint = new IPEndPoint(addressList[addressList.Length - 1], port);  
this.clientSocket = new Socket(this.hostEndPoint.AddressFamily,  SocketType.Stream, ProtocolType.Tcp);  
}  
internal void Connect()  
{  
SocketAsyncEventArgs connectArgs = new SocketAsyncEventArgs();  
connectArgs.UserToken = this.clientSocket;  
connectArgs.RemoteEndPoint = this.hostEndPoint;  
connectArgs.Completed += new EventHandler<SocketAsyncEventArgs>(OnConnect);  
clientSocket.ConnectAsync(connectArgs);  
autoConnectEvent.WaitOne();  
SocketError errorCode = connectArgs.SocketError;  
if (errorCode != SocketError.Success)  
{ 
throw new SocketException((Int32)errorCode);  
}  
}  
internal void Disconnect()  
{  
clientSocket.Disconnect(false);  
}  
private void OnConnect(object sender, SocketAsyncEventArgs e)  
{  
autoConnectEvent.Set();  
this.connected = (e.SocketError == SocketError.Success);  
}  
internal String SendReceive(String message)  
{  
if (this.connected)  
{  
Byte[] sendBuffer = Encoding.ASCII.GetBytes(message);  
SocketAsyncEventArgs completeArgs = new SocketAsyncEventArgs();  
completeArgs.SetBuffer(sendBuffer, 0, sendBuffer.Length); 
completeArgs.UserToken = this.clientSocket; 
    completeArgs.RemoteEndPoint = this.hostEndPoint; 
    completeArgs.Completed += new EventHandler<SocketAsyncEventArgs>(OnSend);  
clientSocket.SendAsync(completeArgs);  
    AutoResetEvent.WaitAll(autoSendReceiveEvents);  
return Encoding.ASCII.GetString(completeArgs.Buffer, completeArgs.Offset,completeArgs.BytesTransferred);  
} 
else  
{  
throw new SocketException((Int32)SocketError.NotConnected);  
}  
} 

в то время как на стороне сервера код выглядит следующим образом:

SocketListener sl = new SocketListener(numConnections, bufferSize);  
sl.Start(port);  
Console.WriteLine("Server listening on port {0}. 
Press any key to terminate the server process...", port);  
Console.Read();  
sl.Stop();  

Слушатель сокетов - это мой класс, который содержит этот метод и конструктор:

internal SocketListener(Int32 numConnections, Int32 bufferSize)  
{  
    this.numConnectedSockets = 0; 
    this.numConnections = numConnections; 
this.bufferSize = bufferSize;  
this.readWritePool = new SocketAsyncEventArgsPool(numConnections);  
this.semaphoreAcceptedClients = new Semaphore(numConnections, numConnections);  
for (Int32 i = 0; i < this.numConnections; i++)  
{  
SocketAsyncEventArgs readWriteEventArg = new SocketAsyncEventArgs();  
readWriteEventArg.Completed += new EventHandler<SocketAsyncEventArgs> (OnIOCompleted);  
readWriteEventArg.SetBuffer(new Byte[this.bufferSize], 0, this.bufferSize);  
this.readWritePool.Push(readWriteEventArg);  
}  
} 
internal void Start(Int32 port) 
{  
IPAddress[] addressList = Dns.GetHostEntry(Environment.MachineName).AddressList;  
IPEndPoint localEndPoint = new IPEndPoint(addressList[addressList.Length - 1], port);  
this.listenSocket = new Socket(localEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);  
this.listenSocket.ReceiveBufferSize = this.bufferSize;  
      this.listenSocket.SendBufferSize = this.bufferSize;  
if (localEndPoint.AddressFamily == AddressFamily.InterNetworkV6)  
{  
this.listenSocket.SetSocketOption(SocketOptionLevel.IPv6, (SocketOptionName)27, false);  
this.listenSocket.Bind(new IPEndPoint(IPAddress.IPv6Any, localEndPoint.Port));  
}  
else  
{  
this.listenSocket.Bind(localEndPoint);  
}  
this.listenSocket.Listen(this.numConnections);  
this.StartAccept(null);  
mutex.WaitOne();  
}  

У меня уже есть порт для моего маршрутизатора из-за серверной части exe, которая не прослушивала без переадресации портов.
работает нормально с отправкой и получением на том же ПК и в том же порту дома.
Хотя, когда я пытаюсь запустить оба кодов ехе на моем рабочем компьютере он бросает исключение в следующей строке:

Exception thrown by socket

Может ли один наставит меня, Что проблема и как решить ее?
Спасибо

ответ

0

Вы пытались временно отключить брандмауэр Windows?

+0

Я не могу, потому что в моем офисе работает сервер, который работает сетевым инженером, я не могу сказать ему, что он будет делать, потому что это будет проблема безопасности. Я тоже могу подумать, что это проблема блокировки межсетевого экрана не может разрешите его с помощью некоторой логики кода ... любой источник ... спасибо –

+0

Вы можете попробовать порт 80 вместо пользовательского, чтобы узнать, открыты ли они. – Panda

+0

Я пытаюсь использовать эти порты, но он отвечает, что порт уже используется –