Server side
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class VarTest104
{
public static void main(String[]
args) throws IOException {
ServerSocket serversocket
= new ServerSocket(9999);
//서버 소켓을 생성한다 .포트는
(9999)
System. out .println("서버준비
완료!" );
Socket socket =
serversocket.accept();
// 소켓을 생성하는데 리스닝 상태로 만듬//신호를
받으면 socket에 담음
System. out .println("클라이언트 연결
완료!" );
InputStream in =
socket.getInputStream();
//socket메소드중 Stream을 만드는 객채발동 서 in에 담음
DataInputStream dis
= new DataInputStream(in); //input
OutputStream out=
socket.getOutputStream(); //socket에서OutputStream
DataOutputStream dos
= new
DataOutputStream(out);//output
while (true ){
String usrMsg =
dis.readUTF();
System. out .println("사용자 메세지 :
" +usrMsg);
if (usrMsg.equals("EXIT" )){
break ;
}
dos.writeUTF(usrMsg);
dos.flush(); //찌꺼기
털어주기.
}
dos.close();
out.close();
dis.close();
in.close();
socket.close();
serversocket.close();
}
}
Client side
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class DataInputTest
{
public static void main(String[]
args) throws IOException{
Socket socket
= new Socket("localhost" ,9999); //클라이언트
입장입니다.
System. out .println("서버 연결
완료!" );
OutputStream out =
socket.getOutputStream(); //socket에 기능중 Stream을 불러와 out에 담는다.
DataOutputStream dos
= new DataOutputStream(out);
InputStream in =
socket.getInputStream();
DataInputStream dis
= new DataInputStream(in);
Scanner s = new Scanner(System. in );
while (true ){
System. out .println("서버로 전송할
메세지를 입력해주세요.");
String msg
=s.nextLine(); //메세지 입력
dos.writeUTF(msg); //OutputStream이용해서 쓴가
dos.flush(); // 버퍼의 내용을
전부 밀어 넣는다.
String readMsg =
dis.readUTF(); //내가 보낸 메시지 출력
System. out .println("받은메세지=" +readMsg);
if (msg.equals("EXIT" )){
break ;
} //if
문
} //while문
dis.close();
in.close();
dos.close();
out.close();
socket.close();
}
}
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class DataInputTest
{
public static void main(String[]
args) throws IOException{
Socket socket
= new Socket("localhost" ,9999); //클라이언트
입장입니다.
System. out .println("서버 연결
완료!" );
OutputStream out =
socket.getOutputStream(); //socket에 기능중 Stream을 불러와 out에 담는다.
DataOutputStream dos
= new DataOutputStream(out);
InputStream in =
socket.getInputStream();
DataInputStream dis
= new DataInputStream(in);
Scanner s = new Scanner(System. in );
while (true ){
System. out .println("서버로 전송할
메세지를 입력해주세요.");
String msg
=s.nextLine(); //메세지 입력
dos.writeUTF(msg); //OutputStream이용해서 쓴가
dos.flush(); // 버퍼의 내용을
전부 밀어 넣는다.
String readMsg =
dis.readUTF(); //내가 보낸 메시지 출력
System. out .println("받은메세지=" +readMsg);
if (msg.equals("EXIT" )){
break ;
} //if
문
} //while문
dis.close();
in.close();
dos.close();
out.close();
socket.close();
}
}
'Class > socket class' 카테고리의 다른 글
| ServerSocket Class(java) (0) | 2014.08.14 |
|---|---|
| Java-TCP(Server,Client) 프로그램 작성 (0) | 2014.08.12 |
| 자바를 이용한 TCP소켓프로그래밍.. (0) | 2014.03.23 |
?
