Archive
내일이 최종
오늘의 한 줄 총평 : 내일이 최종
오늘 꽤나 진전이 많았다. 원래 목표였던 1차 완성을 지나서 여러 기능들을 추가적으로 넣고 있다. 채팅기능까지 구현이 끝나면 리팩토링해서 최종 완성을 해야겠다.
오늘의 한 줄 총평 : 고지가 보인다
Unicasting
/**
* 서버는 스레드를 생성하여 클라이언트와 통신하는 소켓을 유지해야함
* 각각의 스레드가 개별 클라이언트와 통신 할 수 있도록 구현
*/
// Server
import java.io.*;
import java.net.*;
public class UnicastServer {
public UnicastServer() {
ServerSocket ss = null;
try {
ss = new ServerSocket(5001);
} catch(IOException e) {
System.out.println("해당 포트가 사용중입니다.");
System.exit(0);
}
try {
while(true) {
System.out.println("서버 대기중");
Socket s = ss.accept();
// 클라이언트와 채팅할 스레드 생성
UnicastServerThread thread =
new UnicastServerThread(s);
thread.start();
}
} catch(IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new UnicastServer();
}
}
// Thread
import java.io.*;
import java.net.*;
public class UnicastServerThread extends Thread {
Socket s = null;
BufferedReader br = null;
BufferedWriter bw = null;
// 객체 생성시 서버의 소켓을 받아서 저장
public UnicastServerThread(Socket s) {
this.s = s;
}
@Override
public void run() {
// 스트림 연결
try {
br = new BufferedReader(new InputStreamReader(s.getInputStream()));
bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
while(true) {
// 클라이언트가 전달한 메세지 수신
String msg = br.readLine();
System.out.println(msg);
// 클라이언트에게 메세지 전송
bw.write(msg+"\n");
bw.flush();
}
} catch(IOException e) {
InetAddress ip = s.getInetAddress();
String address = ip.getHostAddress();
System.out.println("["+address+"] 와의 연결이 끊어졌습니다.");
}
}
}
// Client
import java.io.*;
import java.net.*;
public class UnicastClient {
Socket s = null;
BufferedReader br = null;
BufferedWriter bw = null;
BufferedReader keyboard = null;
public UnicastClient() {
try {
s = new Socket("localHost", 5001);
} catch(UnknownHostException e) {
System.out.println("서버를 찾을 수 없습니다.");
System.exit(0);
} catch(IOException e) {
System.out.println("서버와 연결할 수 없습니다.");
System.exit(0);
}
try {
// keyboard와 연결된 스트림 얻기
keyboard = new BufferedReader(
new InputStreamReader(System.in));
bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
br = new BufferedReader(new InputStreamReader(s.getInputStream()));
// 소켓으로부터 스트림 얻기
while(true) {
// 키보드 입력
System.out.print("전송할 메세지 : ");
String msg = keyboard.readLine();
// 메세지 서버로 전송
bw.write(msg+"\n");
bw.flush();
// 서버에세 메세지 수신
String getMsg = br.readLine();
System.out.println("수신 메세지 : "+getMsg);
}
} catch(IOException e) {
System.out.println("서버와의 연결이 끊어졌습니다.");
System.exit(0);
}
}
public static void main(String[] args) {
new UnicastClient();
}
}
Multicasting
/**
* Server
* 모든 클라이언트의 연결요청을 받아서 socket을 생성하고 thread를 생성한다.
* 생성된 thread를 Collection에 저장한다.
*/
import java.io.*;
import java.net.*;
import java.util.*;
public class MulticastServer {
private ArrayList<MultiServerThread> clientList = new ArrayList<>();
private ServerSocket ss = null;
public MulticastServer() {
try {
ss = new ServerSocket(5002);
System.out.println("서버 대기중");
while(true) {
Socket s = ss.accept();
InetAddress ip = s.getInetAddress();
String address = ip.getHostAddress();
System.out.println(address+" 접속");
// 스레드 객체 생성
MultiServerThread t = new MultiServerThread(clientList, s);
t.start();
// 생성된 스레드를 리스트에 저장
clientList.add(t);
}
}catch(IOException e) {
System.out.println(e.getMessage());
}
}
public static void main(String[] args) {
new MulticastServer();
}
}
// Server Thread
import java.io.*;
import java.net.*;
import java.util.ArrayList;
public class MultiServerThread extends Thread {
private Socket s;
private BufferedReader in;
private PrintWriter out;
private ArrayList<MultiServerThread> clientList;
public MultiServerThread(ArrayList<MultiServerThread> clientList, Socket s) {
this.s = s;
this.clientList = clientList;
}
@Override
public synchronized void run() {
try {
in = new BufferedReader(new InputStreamReader(s.getInputStream()));
out = new PrintWriter(s.getOutputStream());
while(true) {
String msg = in.readLine();
broadCasting(msg);
}
} catch(IOException e) {
clientList.remove(this);
String ip = s.getInetAddress().getHostAddress();
try {
broadCasting(ip+"와의 연결이 끊어졌습니다.");
} catch(IOException ioe) {
ioe.printStackTrace();
}
}
}
// 접속자 모두에게 메세지 전송
public void broadCasting(String msg) throws IOException {
for (MultiServerThread t : clientList) {
t.sendMsg(msg);
}
}
// 메세지 전송 메소드
public void sendMsg(String msg) throws IOException {
out.println(msg);
out.flush();
}
}
// Client
import java.io.*;
import java.net.*;
public class MulticastClient {
private Socket s;
private BufferedReader in;
private PrintWriter out;
private BufferedReader keyboard;
public MulticastClient() {
try {
s = new Socket("localhost", 5002);
System.out.println("서버 접속 성공");
keyboard = new BufferedReader(new InputStreamReader(System.in));
out = new PrintWriter(s.getOutputStream(),true);
in = new BufferedReader(new InputStreamReader(s.getInputStream()));
MultiClientThread t = new MultiClientThread(in);
t.start();
while(true) {
String msg = keyboard.readLine();
out.println(msg);
}
} catch(UnknownHostException e) {
e.printStackTrace();
} catch(IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new MulticastClient();
}
}
// Client Thread
import java.io.*;
public class MultiClientThread extends Thread {
private BufferedReader in;
public MultiClientThread(BufferedReader in) {
this.in = in;
}
@Override
public void run() {
try {
while(true) {
String msg = in.readLine();
System.out.println("수신 메세지 : "+msg);
}
} catch(IOException e) {
e.printStackTrace();
}
}
}
KG아이티뱅크 자바 강의자료
InetAddress 클래스
import java.net.*;
public class IdnetAddressEx {
public static void main(String[] args) {
//InetAddress는 ip정보와 Host정보를 가지는 객체
//InetAddress객체는 static 메소드를 이용해 생성
try {
//Host이름에 해당되는 ip정보를 가진 InetAddress객체 얻기
InetAddress ipInfo1 = InetAddress.getByName("www.daum.net");
//ip주소 얻기
String ip = ipInfo1.getHostAddress();
System.out.println("ip 주소 : "+ip);
//Host이름에 해당되는 ip정보를 가진 모든 InetAddress객체 얻기
InetAddress[] ipArray = InetAddress.getAllByName("www.daum.net");
for(InetAddress temp : ipArray) {
System.out.println(temp);
}
//현재 컴퓨터의 ip정보를 가진 InetAddress객체 얻기
InetAddress myHost = InetAddress.getLocalHost();
System.out.println("Host : "+myHost.getHostName());
System.out.println("Host ip : "+myHost.getHostAddress());
} catch(UnknownHostException e) {
e.printStackTrace();
}
}
}
/**
실행결과 :
ip 주소 : 203.133.167.16
www.daum.net/203.133.167.16
www.daum.net/211.231.99.80
Host : DESKTOP-xxxxxx
Host ip : 192.xxx.xxx.x
*/
URL 클래스
import java.io.*;
import java.net.*;
public class UrlEx {
public static void main(String[] args) {
BufferedReader br = null;
try {
//url 객체로부터 여러 정보들을 얻을 수 있다
URL url = new URL("http://daum.net/index.html");
System.out.println("프로토콜 : "+url.getProtocol());
System.out.println("호스트 : "+url.getHost());
System.out.println("포트번호 : "+url.getPort());
System.out.println("경로 : "+url.getPath());
System.out.println("파일 : "+url.getFile());
//보안상의 이유로 출력이 안될 수 있다
br = new BufferedReader(new InputStreamReader(url.openStream()));
String str = null;
while((str = br.readLine()) != null) {
System.out.println(str);
}
} catch(MalformedURLException e) {
e.printStackTrace();
} catch(IOException e) {
e.printStackTrace();
} finally {
try {if(br!=null)br.close();}catch(IOException e) {}
}
}
URLConnection 클래스
import java.net.*;
import java.io.*;
public class URLConnectionEx {
public static void main(String[] args) {
BufferedReader br = null;
try {
URL url = new URL("http://www.kgitbank.co.kr");
URLConnection uc = url.openConnection();
uc.connect();
String str = null;
br = new BufferedReader(new InputStreamReader(uc.getInputStream()));
while((str = br.readLine())!= null) {
System.out.println(str);
}
} catch(MalformedURLException e) {
e.printStackTrace();
} catch(IOException e) {
e.printStackTrace();
} finally {
try {if(br!=null)br.close();}catch(IOException e) {}
}
}
}
socket 클래스
ServerSocket 클래스
/**
* Server
*/
import java.net.*;
import java.io.*;
public class EchoServer {
public EchoServer() {
// 1. 서버소켓 생성
try {
ServerSocket ss = new ServerSocket(5000);
System.out.println("서버 대기중");
// 2. 클라이언트의 요청 대기
Socket s = ss.accept();
System.out.println("클라이언트 연결 - 소켓 생성");
// 접속한 클라이언트 정보 얻기
InetAddress ia = s.getInetAddress();
String ip = ia.getHostAddress();
System.out.println("["+ip+"] 접속");
// 3. 소켓으로부터 Input,OutputStream 얻기
InputStream is = s.getInputStream();
OutputStream os = s.getOutputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
// 4. 클라이언트가 전송한 메세지 읽기
String message = br.readLine();
System.out.println("[메세지] : "+message);
// 5. 클라이언트에게 메세지 전송하기
bw.write("["+ip+"] 님 환영합니다.\n");
bw.flush();
} catch (IOException e) {
// 지정한 포트번호가 사용중일시 예외 발생
System.out.println("해당 포트번호는 사용중입니다.");
}
}
public static void main(String[] args) {
new EchoServer();
}
}
/**
* Client
*/
import java.io.*;
import java.net.*;
public class EchoClient {
public EchoClient() {
try {
// 1. 서버와 통신할 소켓 생성
Socket s = new Socket("localHost", 5000);
// 2. 소켓으로부터 input,outputStream 얻기
OutputStream os = s.getOutputStream();
InputStream is = s.getInputStream();
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
BufferedReader br = new BufferedReader(new InputStreamReader(is));
// 3. 서버에 메세지 전송하기
bw.write("나는 클라이언트다.\n");
bw.flush();
// 4. 서버가 보낸 메세지 받기
String message = br.readLine();
System.out.println("[서버가 보낸 메세지] : "+message);
} catch(UnknownHostException e) {
// ip에 해당하는 서버를 찾을 수 없는 경우
System.out.println("서버를 찾을 수 없습니다.");
} catch(IOException e) {
// 해당 포트번호에 어떤 서비스도 존재하지 않는 경우
System.out.println("사용할 수 없는 포트번호입니다.");
}
}
public static void main(String[] args) {
new EchoClient();
}
}
KG아이티뱅크 자바 강의자료
완성을 목전에 두고 쉬고 싶다는 생각이 부쩍 많이 든다. 우선 최선을 다해 완성을 하고 마음을 추스르고 다음 스텝을 준비해야겠다. 최근엔 개인 프로젝트의 완성에만 매달려있어서 다른 공부를 못했었기에 얼른 리액트 공부할 준비도 하고 주말엔 알고리즘도 공부하고 블로그 포스팅도 많이많이 해야지.
오늘의 한 줄 총평 : 개인 프로젝트는 폭업 사냥터같은 느낌?