찾다
Javajava지도 시간C#(소켓) 비동기 소켓 코드 예제

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


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

C#

System.Net 사용,
System.Net.Sockets 사용,
System.Text 사용;
// 원격 장치로부터 데이터를 수신하기 위한 상태 개체.
public class StateObject {
// 클라이언트 소켓.
public Socket workSocket = null
// 수신 버퍼 크기. >public const int BufferSize = 256;
// 수신 버퍼
public byte[] buffer = new byte[BufferSize]
// 수신된 데이터 문자열
);
}
public class AsynchronousClient {
// 원격 장치의 포트 번호
private const int port = 11000;// ManualResetEvent 인스턴스 신호 완료
static ManualResetEvent connectDone =
new ManualResetEvent(false);
private static ManualResetEvent sendDone =
new ManualResetEvent(false)
private static ManualResetEvent receiveDone =
new ManualResetEvent(false ); // 원격 장치의 응답
private static String response = String.Empty;
private static void StartClient() {
// 원격 장치에 연결합니다.
// 소켓에 대한 원격 끝점을 설정합니다.
//
// 원격 장치의 이름은 "host.contoso.com"입니다.
IPHostEntry ipHostInfo = Dns.Resolve("host.contoso. com");
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint RemoteEP = new IPEndPoint(ipAddress, port);
// TCP/IP 소켓을 생성합니다.
소켓 클라이언트 = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
// 원격 엔드포인트에 연결합니다.
client.BeginConnect(remoteEP,
new AsyncCallback(ConnectCallback), client);
connectDone.WaitOne();// 원격 장치에 테스트 데이터를 보냅니다.
Send(client,"This is a test")
sendDone.WaitOne(); 🎜>// 원격 장치로부터 응답을 받습니다.
receiveDone.WaitOne()
// 콘솔에 응답을 씁니다. received : {0}", response);
// 소켓을 해제합니다.
client.Shutdown(SocketShutdown.Both);
client.Close();
} catch(예외 e) {
Console.WriteLine(e.ToString());
}
}
private static void ConnectCallback(IAsyncResult ar) {
try {
// 상태에서 소켓 검색 object.
Socket client = (Socket) ar.AsyncState;
// 연결을 완료합니다.
client.EndConnect(ar)
Console.WriteLine("소켓이 {0}에 연결됨",
client.RemoteEndPoint.ToString());
// 연결이 이루어졌다는 신호
connectDone.Set()
} catch (Exception e) {
Console.WriteLine (e.ToString());
}
}
private static void receive(Socket client) {
try {
// StateObject를 생성합니다. state = new StateObject();
state.workSocket = client
// 원격 장치로부터 데이터 수신을 시작합니다.
client.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0, 
new AsyncCallback(ReceiveCallback), state); 
} catch (예외 e) { 
Console.WriteLine(e.ToString()); 


private static void ReceiveCallback(IAsyncResult ar) { 
시도 { 
// 비동기 상태 객체에서 상태 객체와 클라이언트 소켓을 검색하세요.
//. 
StateObject 상태 =(StateObject) ar.AsyncState; 
소켓 클라이언트 = state.workSocket; 
//원격 기기에서 데이터를 읽습니다. 
int bytesRead = client.EndReceive(ar); 
if (bytesRead > 0) { 
// 더 많은 데이터가 있을 수 있으므로 지금까지 받은 데이터를 저장하세요. 
state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead)); 
// 나머지 데이터를 가져옵니다. 
client.BeginReceive(state.buffer,0,StateObject.BufferSize,0, 
new AsyncCallback(ReceiveCallback), state); 
} else { 
// 모든 데이터가 도착했습니다. 이에 대해 응답해 보세요. 
if (state.sb.Length > 1) { 
응답 = state.sb.ToString(); 

// 모든 바이트가 수신되었음을 알립니다. 
receiveDone.Set(); 

} catch (예외 e) { 
Console.WriteLine(e.ToString()); 


private static void Send(소켓 클라이언트, 문자열 데이터) { 
// ASCII 인코딩을 사용하여 문자열 데이터를 바이트 데이터로 변환합니다. 
byte[] byteData = Encoding.ASCII.GetBytes(data); 
// 원격 기기로 데이터 전송을 시작합니다. 
client.BeginSend(byteData, 0, byteData.Length, 0, 
new AsyncCallback(SendCallback), client); 

private static void SendCallback(IAsyncResult ar) { 
try { 
// 상태 객체에서 소켓을 검색합니다. 
소켓 클라이언트==(소켓)ar.AsyncState; 
// 원격 기기로 데이터 전송을 완료합니다. 
int bytesSent = client.EndSend(ar); 
Console.WriteLine("{0}바이트를 서버로 보냈습니다.", bytesSent); 
// 모든 바이트가 전송되었음을 알립니다. 
sendDone.Set(); 
} catch (예외 e) { 
Console.WriteLine(e.ToString()); 


public static int Main(String[] args) { 
StartClient(); 
0을 반환합니다. 


异步服务器套接字示例 하측면의 인터넷은 示例程序创建一个接收来自客户端的连接请求的服务器.该服务器是用异步套接字生成的, 
因此在等待来自客户端的连接时不挂起服务器应用程序该字符.串,然后将该字符串回显到客户端。来自客户端 字符串必须包含字符串“”, 
以发流表示消息结尾的信号。 



  




C#
 复system代码 

시스템 사용; 
System.Net 사용; 
System.Net.Socket 사용; 
System.Text 사용; 
System.Threading 사용; 
// 클라이언트 데이터를 비동기적으로 읽기 위한 상태 개체
공개 클래스 StateObject{
//클라이언트 소켓. 
공용 소켓 workSocket = null; 
// 수신 버퍼의 크기입니다. 
공용 상수 int BufferSize = 1024; 
// 버퍼를 수신합니다. 
공개 바이트[] 버퍼 = 새 바이트[BufferSize]; 
// 수신된 데이터 문자열입니다. 
공개 StringBuilder sb = 새 StringBuilder(); 

공용 클래스 AsynchronousSocketListener { 
//스레드 신호. 
공개 정적 ManualResetEvent allDone = 새 ManualResetEvent(false); 
public AsynchronousSocketListener() { 

public static void StartListening() { 
// 수신 데이터용 데이터 버퍼입니다. 
바이트[] 바이트 = 새 바이트[1024]; 
//소켓의 로컬 엔드포인트를 설정합니다. 
// 리스너를 실행하는 컴퓨터의 DNS 이름은
// 'host.contoso.com'입니다. 
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(100); 
while(true) { 
// 이벤트를 비신호 상태로 설정합니다. 
allDone.Reset(); 
// 비동기 소켓을 시작하여 연결을 수신합니다. 
Console.WriteLine("연결을 기다리는 중..."); 
listener.BeginAccept( 
new AsyncCallback(AcceptCallback), 
리스너 ); 
// 계속하기 전에 연결이 이루어질 때까지 기다리세요. 
allDone.WaitOne(); 

} catch (예외 e) { 
Console.WriteLine(e.ToString()); 

Console.WriteLine("n계속하려면 Enter를 누르세요..."); 
Console.Read(); 

public static void AcceptCallback(IAsyncResult ar) { 
// 메인 스레드에 계속하라는 신호를 보냅니다. 
allDone.Set(); 
// 클라이언트 요청을 처리하는 소켓을 가져옵니다. 
소켓 리스너=(Socket) ar.AsyncState; 
소켓 처리기==listener.EndAccept(ar); 
// 상태 객체를 생성합니다. 
StateObject 상태 = 새 StateObject(); 
state.workSocket = 핸들러; 
handler.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0, 
new AsyncCallback(ReadCallback), state); 

공개 정적 void ReadCallback(IAsyncResult ar){ 
문자열 콘텐츠 = String.Empty; 
// 비동기 상태 개체에서 상태 개체와 핸들러 소켓을 검색합니다
//. 
StateObject 상태 =(StateObject) ar.AsyncState; 
소켓 핸들러 = state.workSocket; 
//클라이언트 소켓에서 데이터를 읽습니다.  
int bytesRead = handler.EndReceive(ar); 
if (bytesRead > 0) { 
// 더 많은 데이터가 있을 수 있으므로 지금까지 받은 데이터를 저장하세요. 
state.sb.Append(Encoding.ASCII.GetString( 
state.buffer,0,bytesRead)); 
// 파일 끝 태그를 확인하세요. 거기에 없으면
//더 많은 데이터를 읽어보세요. 
콘텐츠 = state.sb.ToString(); 
if (content.IndexOf("") > -1) { 
// 모든 데이터를 
// 클라이언트에서 읽었습니다. 콘솔에 표시하세요. 
Console.WriteLine("소켓에서 {0}바이트를 읽습니다. n 데이터: {1}",
content.Length, content ); 
// 데이터를 클라이언트에 다시 에코합니다. 
보내기(처리기, 콘텐츠); 
} else { 
// 모든 데이터가 수신되지는 않았습니다. 더 많은 것을 얻으세요. 
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, 
new AsyncCallback(ReadCallback), state); 



private static void Send(소켓 핸들러, 문자열 데이터) { 
// ASCII 인코딩을 사용하여 문자열 데이터를 바이트 데이터로 변환합니다. 
byte[] byteData = Encoding.ASCII.GetBytes(data);
// 원격 장치로 데이터 전송을 시작합니다.
handler.BeginSend(byteData, 0, byteData.Length, 0,
new AsyncCallback (SendCallback), handler);
}
private static void SendCallback(IAsyncResult ar) {
try {
// 상태 객체에서 소켓을 검색합니다.
소켓 핸들러 = (소켓) ar.AsyncState;
// 원격 장치로 데이터 전송을 완료합니다.
int bytesSent = handler.EndSend(ar);
Console.WriteLine("클라이언트에 {0}바이트를 보냈습니다.", bytesSent );
handler.Shutdown(SocketShutdown.Both);
handler.Close()
} catch(예외 e) {
Console.WriteLine(e.ToString()); }
}
public static int Main(String[] args) {
StartListening();
return 0;
}
}

위는 C#입니다. (소켓) 비동기 소켓 코드 예제, 더 많은 관련 내용을 보려면 PHP 중국어 웹사이트(www.php.cn)에 주목하세요!



성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
플랫폼 독립성을 위해 기본 코드를 통해 바이트 코드를 사용하는 장점은 무엇입니까?플랫폼 독립성을 위해 기본 코드를 통해 바이트 코드를 사용하는 장점은 무엇입니까?Apr 30, 2025 am 12:24 AM

Bytecodeachievesplatformincendence는 executedbirtualmachine (vm)을 beenecutedbyavirtmachine (vm)을 허용합니다

Java는 진정으로 100% 플랫폼 독립적입니까? 왜 또는 왜 그렇지 않습니까?Java는 진정으로 100% 플랫폼 독립적입니까? 왜 또는 왜 그렇지 않습니까?Apr 30, 2025 am 12:18 AM

Java는 100% 플랫폼 독립성을 달성 할 수 없지만 플랫폼 독립성은 JVM 및 바이트 코드를 통해 구현되어 코드가 다른 플랫폼에서 실행되도록합니다. 특정 구현에는 다음이 포함됩니다. 1. 바이트 코드로의 컴파일; 2. JVM의 해석 및 실행; 3. 표준 라이브러리의 일관성. 그러나 JVM 구현 차이, 운영 체제 및 하드웨어 차이, 타사 라이브러리의 호환성은 플랫폼 독립성에 영향을 줄 수 있습니다.

Java의 플랫폼 독립성은 코드 유지 가능성을 어떻게 지원합니까?Java의 플랫폼 독립성은 코드 유지 가능성을 어떻게 지원합니까?Apr 30, 2025 am 12:15 AM

Java는 "Writ 2. 유지 보수 비용이 낮 으면 하나의 수정 만 필요합니다. 3. 높은 팀 협업 효율성은 높고 지식 공유에 편리합니다.

새로운 플랫폼을 위해 JVM을 만드는 데 어떤 어려움이 있습니까?새로운 플랫폼을 위해 JVM을 만드는 데 어떤 어려움이 있습니까?Apr 30, 2025 am 12:15 AM

새로운 플랫폼에서 JVM을 만드는 주요 과제에는 하드웨어 호환성, 운영 체제 호환성 및 성능 최적화가 포함됩니다. 1. 하드웨어 호환성 : JVM이 RISC-V와 같은 새로운 플랫폼의 프로세서 명령어 세트를 올바르게 사용할 수 있도록해야합니다. 2. 운영 체제 호환성 : JVM은 Linux와 같은 새로운 플랫폼의 시스템 API를 올바르게 호출해야합니다. 3. 성능 최적화 : 성능 테스트 및 튜닝이 필요하며 쓰레기 수집 전략은 새로운 플랫폼의 메모리 특성에 적응하도록 조정됩니다.

Javafx 라이브러리는 GUI 개발에서 플랫폼 불일치를 어떻게 해결하려고 시도합니까?Javafx 라이브러리는 GUI 개발에서 플랫폼 불일치를 어떻게 해결하려고 시도합니까?Apr 30, 2025 am 12:01 AM

javafxeffecticallydressessplatforminconsistenciesinguedevelopment는 aplatform-agnosticscenegraphandcsstyling을 사용하여 development.1) itabstractsplatformspecificsthroughascenegraph, csstyling allowsforfine-tunin을 보장합니다

JVM이 Java 코드와 기본 운영 체제 사이의 중개자 역할을하는 방법을 설명하십시오.JVM이 Java 코드와 기본 운영 체제 사이의 중개자 역할을하는 방법을 설명하십시오.Apr 29, 2025 am 12:23 AM

JVM은 Java 코드를 기계 코드로 변환하고 리소스를 관리하여 작동합니다. 1) 클래스로드 : .class 파일을 메모리에로드하십시오. 2) 런타임 데이터 영역 : 메모리 영역 관리. 3) 실행 엔진 : 해석 또는 컴파일 바이트 코드. 4) 로컬 메소드 인터페이스 : JNI를 통해 운영 체제와 상호 작용합니다.

Java의 플랫폼 독립성에서 JVM (Java Virtual Machine)의 역할을 설명하십시오.Java의 플랫폼 독립성에서 JVM (Java Virtual Machine)의 역할을 설명하십시오.Apr 29, 2025 am 12:21 AM

JVM을 통해 Java는 플랫폼을 가로 질러 실행할 수 있습니다. 1) JVM 하중, 검증 및 바이트 코드를 실행합니다. 2) JVM의 작업에는 클래스 로딩, 바이트 코드 검증, 해석 실행 및 메모리 관리가 포함됩니다. 3) JVM은 동적 클래스 로딩 및 반사와 같은 고급 기능을 지원합니다.

Java 응용 프로그램이 다른 운영 체제에서 올바르게 실행되도록하는 데 어떤 조치를 취 하시겠습니까?Java 응용 프로그램이 다른 운영 체제에서 올바르게 실행되도록하는 데 어떤 조치를 취 하시겠습니까?Apr 29, 2025 am 12:11 AM

Java 응용 프로그램은 다음 단계를 통해 다른 운영 체제에서 실행할 수 있습니다. 1) 파일 또는 경로 클래스를 사용하여 파일 경로를 처리합니다. 2) system.getenv ()를 통해 환경 변수를 설정하고 얻습니다. 3) Maven 또는 Gradle을 사용하여 종속성 및 테스트를 관리하십시오. Java의 크로스 플랫폼 기능은 JVM의 추상화 계층에 의존하지만 여전히 특정 운영 체제 별 기능의 수동 처리가 필요합니다.

See all articles

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

Video Face Swap

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

Eclipse용 SAP NetWeaver 서버 어댑터

Eclipse용 SAP NetWeaver 서버 어댑터

Eclipse를 SAP NetWeaver 애플리케이션 서버와 통합합니다.

MinGW - Windows용 미니멀리스트 GNU

MinGW - Windows용 미니멀리스트 GNU

이 프로젝트는 osdn.net/projects/mingw로 마이그레이션되는 중입니다. 계속해서 그곳에서 우리를 팔로우할 수 있습니다. MinGW: GCC(GNU Compiler Collection)의 기본 Windows 포트로, 기본 Windows 애플리케이션을 구축하기 위한 무료 배포 가능 가져오기 라이브러리 및 헤더 파일로 C99 기능을 지원하는 MSVC 런타임에 대한 확장이 포함되어 있습니다. 모든 MinGW 소프트웨어는 64비트 Windows 플랫폼에서 실행될 수 있습니다.

VSCode Windows 64비트 다운로드

VSCode Windows 64비트 다운로드

Microsoft에서 출시한 강력한 무료 IDE 편집기

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

SublimeText3 영어 버전

SublimeText3 영어 버전

권장 사항: Win 버전, 코드 프롬프트 지원!