C#(소켓) 동기 소켓 코드 예

동기식 클라이언트 소켓 예제

다음 예제 프로그램은 서버에 연결하는 클라이언트를 생성합니다. 클라이언트는 동기 소켓으로 생성되므로 서버가 응답을 반환할 때까지 클라이언트 애플리케이션의 실행이 일시 중지됩니다. 애플리케이션은 서버에 문자열을 보낸 다음 서버가 반환한 문자열을 콘솔에 표시합니다.

C#
System.Net 사용,
System.Net.Sockets 사용,
public classSynchronousSocketClient; static void StartClient() {
// 수신 데이터용 데이터 버퍼
byte[] bytes = new byte[1024]
// 원격 장치에 연결합니다.
// 소켓에 대한 원격 끝점을 설정합니다.
// 이 예에서는 로컬 컴퓨터의 포트 11000을 사용합니다.
IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName())
IPAddress ipAddress = ipHostInfo.AddressList [0]; IPEndPoint RemoteEP = new IPEndPoint(ipAddress,11000);
// TCP/IP 소켓을 생성합니다.
소켓 발신자 = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp );
// 소켓을 원격 엔드포인트에 연결합니다.
try {
sender.Connect(remoteEP)
Console.WriteLine("소켓이 {0에 연결되었습니다. }",
sender.RemoteEndPoint.ToString());
// 데이터 문자열을 바이트 배열로 인코딩합니다.
byte[] msg = Encoding.ASCII.GetBytes("이것은 테스트// 소켓을 통해 데이터를 보냅니다.
int bytesSent = sender.Send(msg);
// 원격 장치로부터 응답을 받습니다.
int bytesRec = sender. receive(bytes);
Console.WriteLine("Echoed test = {0}",
Encoding.ASCII.GetString(bytes,0,bytesRec))// 소켓을 해제합니다. sender.Shutdown(SocketShutdown.Both);
sender.Close();
} catch (ArgumentNullException ane) {
Console.WriteLine("ArgumentNullException: {0}",ane.ToString());
} catch(SocketException se) {
Console.WriteLine("SocketException: {0}",se.ToString())
} catch(예외 e) {
Console.WriteLine(" 예기치 않은 예외: {0}", e.ToString());
}
} catch(예외 e) {
Console.WriteLine( e.ToString());
}
}
public static int Main(String[] args) {
StartClient();
return 0;
}
}
동기화 서버 소켓 예제 다음 예제 프로그램은 서버를 생성합니다. 클라이언트로부터 연결 요청을 받는 곳입니다. 서버는 동기 소켓으로 생성되므로
클라이언트의 연결을 기다리는 동안 서버 애플리케이션의 실행을 일시 중단합니다. 애플리케이션은 클라이언트로부터 문자열을 수신하고
콘솔에 문자열을 표시한 다음 해당 문자열을 다시 클라이언트에 에코합니다. 클라이언트에서 오는 문자열에는 메시지 끝을 알리기 위해 "",
문자열이 포함되어야 합니다.








C#
코드 복사

System.Net 사용;
System.Net.Sockets 사용;
System.Text 사용;
public class SynchronousSocketListener {
// 클라이언트에서 들어오는 데이터
public static string data = null; static void StartListening() {
// 수신 데이터에 대한 데이터 버퍼
byte[] bytes = new Byte[1024]// 소켓에 대한 로컬 엔드포인트를 설정합니다.
// Dns .GetHostName은 애플리케이션을 실행하는
// 호스트의 이름을 반환합니다.
IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName())
IPAddress ipAddress = ipHostInfo.AddressList[0];IPEndPoint localEndPoint = 새 IPEndPoint(ipAddress, 11000); 
// TCP/IP 소켓을 만듭니다. 
소켓 리스너 = new Socket(AddressFamily.InterNetwork, 
SocketType.Stream, ProtocolType.Tcp ); 
//소켓을 로컬 엔드포인트에 바인딩하고
//수신 연결을 수신합니다. 
시도해 보세요 { 
listener.Bind(localEndPoint); 
listener.Listen(10); 
// 연결 듣기를 시작하세요. 
while(true) { 
Console.WriteLine("연결을 기다리는 중..."); 
// 연결 수신을 기다리는 동안 프로그램이 일시중지됩니다. 
소켓 핸들러=listener.Accept(); 
데이터 = null; 
// 수신 연결을 처리해야 합니다. 
while (true) { 
바이트 = 새 바이트[1024]; 
int bytesRec = handler.Receive(바이트); 
데이터 += Encoding.ASCII.GetString(bytes,0,bytesRec); 
if (data.IndexOf("") > -1) { 
break; 
} 
} 
// 콘솔에 데이터를 표시합니다. 
Console.WriteLine( "텍스트 수신됨 : {0}", data); 
// 데이터를 클라이언트에 다시 에코합니다. 
byte[] msg = Encoding.ASCII.GetBytes(데이터); 
handler.Send(msg); 
handler.Shutdown(SocketShutdown.Both); 
handler.Close(); 
} 
} catch (예외 e) { 
Console.WriteLine(e.ToString()); 
} 
Console.WriteLine("n계속하려면 Enter를 누르세요..."); 
Console.Read(); 
} 
public static int Main(String[] args) { 
StartListening(); 
0을 반환합니다. 
} 
} 

 以上就是c#(Socket)同步套接字代码示例的内容，更多敳关容请关注PHP中文网（www.php.cn）!