다중 접속 서버 구현
Multi-threading
Multi-threading 을 이용한 다중 접속 서버, 문자열 전송 - 동시에 많은 접속자를 처리할 수 있습니다.
서버 생성
ThreadServer.java
import java.io.*;
import java.net.*;
public class ThreadServer {
public static void main(String[] args) {
System.out.println("****************************************");
System.out.println("Thread를 이용한 다중 접속 서버 작동됨...");
System.out.println("****************************************");
ServerSocket server = null;
int connectCount=0;
try {
server = new ServerSocket(2022);
while(true) {
Socket client = server.accept();
InetAddress ia = client.getInetAddress();
int port = client.getLocalPort();// 접속에 사용된 PORT
String ip = ia.getHostAddress(); // 원격 Client IP
++connectCount; //접속자수 카운트
System.out.print(connectCount);
System.out.print("클라이언트 접속-Local Port: "+ port);
System.out.println(" Client IP: " + ip);
//Client와 통신할 스레드 구현 클래스
Handler handler = new Handler(client);
handler.start();
}
} catch(IOException ioe) {
System.err.println("Exception generated...");
} finally {
try {
server.close();
} catch(IOException ignored) {}
}
}
}Handler.java
class Handler extends Thread {
protected Socket socket;
public Handler(Socket socket) {
//Client와 통신할 객체를 초기값으로 받아 할당합니다.
this.socket = socket;
}
public void run() {
try {
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
//버퍼에 문자열을 기록함
writer.write("스레드 다중접속 서버 접속");
writer.newLine();
writer.write("\n★ 등산했던 산들 ★\n");
writer.write("----------------------------------------\n");
writer.write("1. 관악산, 도봉산, 사패산, 수락산, 파평산");
writer.newLine();
writer.write("\n★ 기억에남는 영화 ★\n");
writer.write("----------------------------------------\n");
writer.write("1. 우주전쟁, 쏘우");
writer.newLine();
//실제로 Client로 전송함
writer.flush();
} catch(IOException ignored) {
} finally {
try {
socket.close();
} catch(IOException ignored) {}
}
}
}클라 생성
ThreadClient.java
import java.io.*;
import java.net.*;
public class ThreadClient {
public static void main(String[] args) {
System.out.println("클라이언트 프로그램 작동.....");
Socket socket = null;
String line; //서버로부터 읽어온 문자열 저장
int cnt=0;
try {
socket = new Socket(args[0], 2022);
InetAddress ia = socket.getInetAddress();
int port = socket.getLocalPort();// 접속에 사용된 PORT
String ip = ia.getHostAddress(); // 원격 Client IP
System.out.print("클라이언트 접속-Local Port: "+ port);
System.out.println(" Server IP: " + ip);
//서버로부터 데이터를 입력받아 버퍼에 저장합니다.
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//버퍼로부터 한 라인씩 읽어 출력합니다.
while(true){
try{
//cnt++;
//System.out.println("순환중입니다.:" + cnt);
//서버로부터 출력되는 내용을 읽어오기위해
//순환하면서 기다립니다.
line = reader.readLine();
if (line == null){
break;
}
//불규칙적으로 입력되는 데이터를 입력 받을시 지정
//Thread.sleep(10);
System.out.println(line);
}catch(Exception e){
System.out.println(e.toString());
}
}
} catch(IOException ioe) {
System.err.println("Exception generated...");
} finally {
try {
socket.close();
System.out.println("서버와의 접속을 종료합니다.");
} catch(Exception ignored) {}
}
//아무키나 누를 때까지 대기합니다.
InputStream is = System.in;
try{
is.read();
}catch(Exception e){
}
System.out.println("서버 프로그램 실행을 종료합니다.");
}
}실행 하기
C:
cd C:서버 경로
start java ThreadServer
start java ThreadClient {고정ip호스팅주소}다중 접속 동시 처리
Multi-threading을 이용한 다중 접속 서버, 난수 발생을 이용한 실시간 주가 전송 - 동시에 많은 접속자를 처리할 수 있습니다.
서버 생성
ThreadServer2.java
import java.io.*;
import java.net.*;
import java.text.*;
public class ThreadServer2 {
public static void main(String[] args) {
System.out.println("****************************************");
System.out.println("Thread를 이용한 다중 접속 서버 작동됨 2..");
System.out.println("****************************************");
ServerSocket server = null;
int connectCount=0;
try {
server = new ServerSocket(2022);
while(true) {
Socket client = server.accept();
InetAddress ia = client.getInetAddress();
int port = client.getLocalPort();// 접속에 사용된 PORT
String ip = ia.getHostAddress(); // 원격 Client IP
++connectCount; //접속자수 카운트
System.out.print(connectCount);
System.out.print("클라이언트 접속-Local Port: "+ port);
System.out.println(" Client IP: " + ip);
//Client와 통신할 스레드 구현 클래스
StockHandler handler = new StockHandler(client);
handler.start();
}
} catch(IOException ioe) {
System.err.println("Exception generated...");
} finally {
try {
server.close();
} catch(IOException ignored) {}
}
}
}StockHandler.java
class StockHandler extends Thread {
protected Socket socket;
public StockHandler(Socket socket) {
//Client와 통신할 객체를 초기값으로 받아 할당합니다.
this.socket = socket;
}
public void run() {
try {
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
double d;
int min=1000;
int max=1000000;
int rnd=0;
int count=0;
DecimalFormat comma = new DecimalFormat("###,##0");
writer.write("개발자A 스레드 다중접속 서버에 접속 하신것을 환영 합니다.");
writer.newLine();
while(true){
count++;
//1000 ~ 1000000 사이의 난수 발생
//----------------------------------
d = Math.random();
rnd = ((int)(d*((max-min)+1))+min);
//----------------------------------
String s = comma.format(rnd);
writer.write("종목:" + count + " 주가:" + s);
writer.newLine();
//Client로 전송함
writer.flush();
sleep(2000); //2초 sleep
}
}catch(InterruptedException e){
System.out.println(e.toString());
}
catch(IOException e) {
System.out.println(e.toString());
}finally {
try {
socket.close();
} catch(IOException ignored) {}
}
}
}클라 생성
ThreadClient2.java
import java.io.*;
import java.net.*;
public class ThreadClient2 {
public static void main(String[] args) {
System.out.println("클라이언트 프로그램 작동.....");
Socket socket = null;
String line; //서버로부터 읽어온 문자열 저장
int cnt=0;
try {
socket = new Socket(args[0], 2022);
InetAddress ia = socket.getInetAddress();
int local_port = socket.getLocalPort();// 접속에 사용된 PORT
int server_port = socket.getPort();// 접속에 사용된 PORT
String ip = ia.getHostAddress(); // 원격 Client IP
System.out.print("클라이언트 접속-Local Port: "+ local_port);
System.out.print(" Server IP: " + ip);
System.out.println(" Server PORT: " + server_port);
//서버로부터 데이터를 입력받아 버퍼에 저장합니다.
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//버퍼로부터 한 라인씩 읽어 출력합니다.
while(true){
System.out.println("순환중입니다.:" + cnt++);
//서버로부터 출력되는 내용을 읽어오기위해
//순환하면서 기다립니다.
line = reader.readLine();
if (line == null){
break;
}
//불규칙적으로 입력되는 데이터를 입력 받을시 지정
Thread.sleep(10);
System.out.println(line);
}
} catch(Exception e) {
System.err.println(e.toString());
} finally {
try {
socket.close();
System.out.println("서버와의 접속을 종료합니다.");
} catch(Exception ignored) {}
}
//아무키나 누를 때까지 대기합니다.
InputStream is = System.in;
try{
is.read();
}catch(Exception e){
}
System.out.println("서버 프로그램 실행을 종료합니다.");
}
}실행 하기
서버 실행
C: cd C:\서버경로 start java ThreadServer2클라이언트 살행 - 추가 CMD 실행
start java ThreadClient2 클라ip 1번 start java ThreadClient2 클라ip 2번 start java ThreadClient2 클라ip 3번
Last updated