소켓 반환 및 전송을 위한 멀티스레드 Java 샘플 코드 찾기

서버

패키지 테스트;

java.net.* 가져오기;

java.io.* 가져오기;

공용 클래스 서버 {

개인 ServerSocket ss;

개인 소켓 소켓;

개인 BufferedReader 입력;

개인 PrintWriter 출력 ;

public Server() {

try {

ss = new ServerSocket(10000);

소켓 = ss.accept ( );

int i=0;

while (true) {

i++;

System.out.println(" 서버 "+i);

String RemoteIP = 소켓.getInetAddress().getHostAddress();

String RemotePort = ":" + 소켓.getLocalPort();

System.out.println("+클라이언트가 들어옵니다!IP:" + RemoteIP

+ RemotePort);

in = new BufferedReader(new InputStreamReader(소켓 p>

.getInputStream()));

String line = in.readLine();

System.out.println("++Cleint send is:" + line);

out = new PrintWriter(socket.getOutputStream(), true);

out.println("++++귀하의 메시지가 수신되었습니다!");

// out.close();

// in.close();

// 소켓.close();

}

} catch (IOException e) {

out.println("++++wrong");

}

시스템 . out.println("서버가 종료되지 않습니다.");

}

public static void main(String[] args) {

new Server( ) ;

}

};

클라이언트

패키지 테스트;

java.io 가져오기.* ;

java.net.* 가져오기;

공용 클래스 클라이언트 {

소켓 소켓;

BufferedReader in;

PrintWriter 출력;

공개

Client() {

try {

System.out.println("-127.0.0.1:10000에 연결 시도");

소켓 = 신규 Socket("127.0.0.1", 10000);

System.out.println("--서버가 연결되었습니다!");

System.out.println("-- -일부 문자를 입력하십시오:");

BufferedReader line;

int i=0;

while(true){

i++;

System.out.println("client "+i);

line = new BufferedReader(new InputStreamReader(

System.in));

out = new PrintWriter(socket.getOutputStream(), true);

out.println(line.readLine());

in = 새로운 BufferedReader (new InputStreamReader(socket

.getInputStream()));

System.out.println("----"+in.readLine());

// out.close();

// in.close();

// 소켓.close();

}

} catch (IOException e) {

out.println("-----Wrong");

}

시스템 .out.println("클라이언트가 종료되지 않습니다");

}

public static void main(String[] args) {

new Client( );

}

};