Q&A와 스터디
//BookServer.java
package bookserver;
import java.util.*;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class BookServer implements ActionListener, Serializable, Runnable {
BookServer server;
static JTextArea text = new JTextArea(20,30);
Socket clientSocket;
static int s1 = 0;
public class ClientHandler implements Runnable {
BufferedReader reader;
Socket sock;
public ClientHandler(Socket clientSocket) {
try {
sock = clientSocket;
InputStreamReader stream = new InputStreamReader(clientSocket.getInputStream());
reader = new BufferedReader(stream);
} catch(Exception ex) {text.append("sock 에러");}
}
public void run() {
String message;
String token = ":";
Essay es = new Essay();
String tmp;
try {
while((message = reader.readLine())!=null) {
StringTokenizer st = new StringTokenizer(message,token);
tmp = st.nextToken();
text.append(tmp+"요청"+'\n');
if(tmp.equals("SHOW")) {
sender("SHOW");
}
else if(tmp.equals("ADD")) {
es.setName(st.nextToken());
es.setAuthor(st.nextToken());
es.setPublisher(st.nextToken());
es.setISBN(st.nextToken());
es.add(es);
}
else if(tmp.equals("QUIT")) {
es.save();
}
else if(tmp.equals("SEARCH1")) {
s1 = es.search(st.nextToken());
sender("SEARCH");
}
else if(tmp.equals("SEARCH2")) {
s1 = es.searchISBN(st.nextToken());
sender("SEARCH");
}
else if(tmp.equals("DEL1")) {
s1 = es.search(st.nextToken());
sender("DEL");
es.del(s1);
}
else if(tmp.equals("DEL2")) {
s1 = es.searchISBN(st.nextToken());
sender("DEL");
es.del(s1);
}
else if(tmp.equals("EDIT1")) {
s1 = es.search(st.nextToken());
sender("EDIT");
es.edit(es, s1);
}
else if(tmp.equals("EDIT2")) {
s1 = es.searchISBN(st.nextToken());
sender("EDIT");
es.edit(es, s1);
}
}
} catch(Exception ex) {text.append("수신 에러"+'\n');}
}
}
public static void main(String[] args) throws IOException {
Essay es = new Essay();
es.load();
text.append("클라이언트의 접속을 기다립니다."+'\n');
Thread t = new Thread(new BookServer());
t.start();
}
public void run() {
JFrame frame = new JFrame("서버");
JPanel panel = new JPanel();
JButton quitbtn = new JButton("종료");
quitbtn.addActionListener(this);
text.setLineWrap(true);
panel.setLayout(new BoxLayout(panel,BoxLayout.Y_AXIS));
JScrollPane scroller = new JScrollPane(text);
text.setLineWrap(true);
scroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_AS_NEEDED);
scroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_AS_NEEDED);
panel.add(scroller);
panel.add(quitbtn);
frame.getContentPane().add(BorderLayout.CENTER,panel);
frame.setSize(500,500);
frame.setVisible(true);
try {
ServerSocket serverSocket = new ServerSocket(13780);
while(true) {
clientSocket = serverSocket.accept();
PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
text.append("접속완료"+'\n');
Thread t = new Thread(new ClientHandler(clientSocket));
t.start();
}
} catch(IOException e) {
JOptionPane.showMessageDialog(null, "포트 연결 실패"+'\n');
System.exit(1);
}
}
public synchronized void sender(String message) {
try {
PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream())));
if(message.equals("SHOW")) {
for(int i=0;i<Essay.essay.size();i++) {
writer.println("SHOW:"+Essay.essay.get(i).getName()+":"+Essay.essay.get(i).getAuthor()+":"+Essay.essay.get(i).getPublisher()+":"+Essay.essay.get(i).getISBN());
writer.flush();
}
}
else if(message.equals("SEARCH")) {
if(s1 != -1) {
writer.println("SEARCH:"+Essay.essay.get(s1).getName()+":"+Essay.essay.get(s1).getAuthor()+":"+Essay.essay.get(s1).getPublisher()+":"+Essay.essay.get(s1).getISBN());
writer.flush();
}
else if(s1 == -1) { // 찾는 도서가 없을 경우
writer.println("SEARCH:NO");
writer.flush();
}
}
else if(message.equals("DEL")) {
if(s1 != -1) {
writer.println("DEL:"+Essay.essay.get(s1).getName()+":"+Essay.essay.get(s1).getAuthor()+":"+Essay.essay.get(s1).getPublisher()+":"+Essay.essay.get(s1).getISBN());
writer.flush();
}
else if(s1 == -1) {
writer.println("SEARCH:NO");
writer.flush();
}
}
else if(message.equals("EDIT")) {
if(s1 != -1) {
}
else if(s1 == -1) {
}
}
} catch(Exception ex) {JOptionPane.showMessageDialog(null, "전송 에러");}
}
public void actionPerformed(ActionEvent ev) {
System.exit(0);
}
}
도서관리 프로그램을 멀티쓰레드 클라이언트/서버로 구현하고 있는데
위코드는 서버 입니다.
그림과 같이 클라이언트 두개를 띄워놓고 A클라이언트에서 도서 목록을 클릭하였는데
B클라이언트에서 목록이 뜹니다. B클라이언트에서 누르면 B에서 뜨구요..
이거... 어디가 잘못된걸까요..?ㅠ;
package bookserver;
import java.util.*;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class BookServer implements ActionListener, Serializable, Runnable {
BookServer server;
static JTextArea text = new JTextArea(20,30);
Socket clientSocket;
static int s1 = 0;
public class ClientHandler implements Runnable {
BufferedReader reader;
Socket sock;
public ClientHandler(Socket clientSocket) {
try {
sock = clientSocket;
InputStreamReader stream = new InputStreamReader(clientSocket.getInputStream());
reader = new BufferedReader(stream);
} catch(Exception ex) {text.append("sock 에러");}
}
public void run() {
String message;
String token = ":";
Essay es = new Essay();
String tmp;
try {
while((message = reader.readLine())!=null) {
StringTokenizer st = new StringTokenizer(message,token);
tmp = st.nextToken();
text.append(tmp+"요청"+'\n');
if(tmp.equals("SHOW")) {
sender("SHOW");
}
else if(tmp.equals("ADD")) {
es.setName(st.nextToken());
es.setAuthor(st.nextToken());
es.setPublisher(st.nextToken());
es.setISBN(st.nextToken());
es.add(es);
}
else if(tmp.equals("QUIT")) {
es.save();
}
else if(tmp.equals("SEARCH1")) {
s1 = es.search(st.nextToken());
sender("SEARCH");
}
else if(tmp.equals("SEARCH2")) {
s1 = es.searchISBN(st.nextToken());
sender("SEARCH");
}
else if(tmp.equals("DEL1")) {
s1 = es.search(st.nextToken());
sender("DEL");
es.del(s1);
}
else if(tmp.equals("DEL2")) {
s1 = es.searchISBN(st.nextToken());
sender("DEL");
es.del(s1);
}
else if(tmp.equals("EDIT1")) {
s1 = es.search(st.nextToken());
sender("EDIT");
es.edit(es, s1);
}
else if(tmp.equals("EDIT2")) {
s1 = es.searchISBN(st.nextToken());
sender("EDIT");
es.edit(es, s1);
}
}
} catch(Exception ex) {text.append("수신 에러"+'\n');}
}
}
public static void main(String[] args) throws IOException {
Essay es = new Essay();
es.load();
text.append("클라이언트의 접속을 기다립니다."+'\n');
Thread t = new Thread(new BookServer());
t.start();
}
public void run() {
JFrame frame = new JFrame("서버");
JPanel panel = new JPanel();
JButton quitbtn = new JButton("종료");
quitbtn.addActionListener(this);
text.setLineWrap(true);
panel.setLayout(new BoxLayout(panel,BoxLayout.Y_AXIS));
JScrollPane scroller = new JScrollPane(text);
text.setLineWrap(true);
scroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_AS_NEEDED);
scroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_AS_NEEDED);
panel.add(scroller);
panel.add(quitbtn);
frame.getContentPane().add(BorderLayout.CENTER,panel);
frame.setSize(500,500);
frame.setVisible(true);
try {
ServerSocket serverSocket = new ServerSocket(13780);
while(true) {
clientSocket = serverSocket.accept();
PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
text.append("접속완료"+'\n');
Thread t = new Thread(new ClientHandler(clientSocket));
t.start();
}
} catch(IOException e) {
JOptionPane.showMessageDialog(null, "포트 연결 실패"+'\n');
System.exit(1);
}
}
public synchronized void sender(String message) {
try {
PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream())));
if(message.equals("SHOW")) {
for(int i=0;i<Essay.essay.size();i++) {
writer.println("SHOW:"+Essay.essay.get(i).getName()+":"+Essay.essay.get(i).getAuthor()+":"+Essay.essay.get(i).getPublisher()+":"+Essay.essay.get(i).getISBN());
writer.flush();
}
}
else if(message.equals("SEARCH")) {
if(s1 != -1) {
writer.println("SEARCH:"+Essay.essay.get(s1).getName()+":"+Essay.essay.get(s1).getAuthor()+":"+Essay.essay.get(s1).getPublisher()+":"+Essay.essay.get(s1).getISBN());
writer.flush();
}
else if(s1 == -1) { // 찾는 도서가 없을 경우
writer.println("SEARCH:NO");
writer.flush();
}
}
else if(message.equals("DEL")) {
if(s1 != -1) {
writer.println("DEL:"+Essay.essay.get(s1).getName()+":"+Essay.essay.get(s1).getAuthor()+":"+Essay.essay.get(s1).getPublisher()+":"+Essay.essay.get(s1).getISBN());
writer.flush();
}
else if(s1 == -1) {
writer.println("SEARCH:NO");
writer.flush();
}
}
else if(message.equals("EDIT")) {
if(s1 != -1) {
}
else if(s1 == -1) {
}
}
} catch(Exception ex) {JOptionPane.showMessageDialog(null, "전송 에러");}
}
public void actionPerformed(ActionEvent ev) {
System.exit(0);
}
}
도서관리 프로그램을 멀티쓰레드 클라이언트/서버로 구현하고 있는데
위코드는 서버 입니다.
그림과 같이 클라이언트 두개를 띄워놓고 A클라이언트에서 도서 목록을 클릭하였는데
B클라이언트에서 목록이 뜹니다. B클라이언트에서 누르면 B에서 뜨구요..
이거... 어디가 잘못된걸까요..?ㅠ;
![[레벨:11]](http://old.lameproof.com/modules/point/icons/default/11.gif "포인트:12461point (75%), 레벨:11/30"){kind=icon}
39쇼핑![[레벨:10]](http://old.lameproof.com/modules/point/icons/default/10.gif "포인트:10868point (98%), 레벨:10/30"){kind=icon}
옛날사람
2010.06.03 12:24:22 (*.222.234.197)
![[레벨:2]](http://old.lameproof.com/modules/point/icons/default/2.gif "포인트:662point (67%), 레벨:2/30"){kind=icon}
녹차한잔 bard님 //답변 정말 감사드립니다.
자바는 처음 접해봐서 배우는중이라...
교재들에 대부분 콘솔작업으로 나와있는데 이것을 GUI로 바꾸는 것도 만만치 않네요...
그런데.. 괜찮으시다면..^^;;
sender 메소드를 ClientHandler가 갖는게 어떤면이 차이가 있는건지 좀 더 설명해주실 수 있으신가요?
자바는 처음 접해봐서 배우는중이라...
교재들에 대부분 콘솔작업으로 나와있는데 이것을 GUI로 바꾸는 것도 만만치 않네요...
그런데.. 괜찮으시다면..^^;;
sender 메소드를 ClientHandler가 갖는게 어떤면이 차이가 있는건지 좀 더 설명해주실 수 있으신가요?
2010.06.03 12:34:24 (*.76.115.36)
![[레벨:6]](http://old.lameproof.com/modules/point/icons/default/6.gif "포인트:4254point (86%), 레벨:6/30"){kind=icon}
bard녹차한잔//
synchronized 구문을 메소드에다 걸어놓으면 해당 메소드에 진입하는 모든 쓰레드는 모니터를 얻어내야 합니다.
즉, 하나의 ClientHander 가 message 를 sending 하기 위해 sender(메소드명을 이렇게 명사로 적는건 안좋습니다. ;])에게 진입하는 순간 다른 ClientHandler 는 이전에 진입한 ClientHandler 가 모니터를 release 하기 전까지는 wait 상태가 되버리죠.
network programming 을 할 때는 synchronized 블럭을 최소화 해야 합니다. 더 안전은 해지겠지만, 동시성은 떨어지게 되고, 자칫 잘못설계된 호출 순서로 인해 deadlock에 빠지기도 하지요..
동시성을 높이는 방법은 여러가지가 있겠습니다만.. 위의 소스에서 보면 clienthandler 간의 interaction 은 거의 없습니다. 따라서 sender 메소드가 synchronized 될 이유는 없는것이죠.
옵션은 두가지가 있습니다. (아니 세가지라고 해야 하나요?)
첫 번째.. 위에서 말씀드렷듯이 ClientHandler 에게 sender 메소드를 줘버린다.
두 번째.. synchronized 구문을 sender 메소드에서 제거하고, clientSocket 을 쓰던 부분을 위에서 말씀드린데로 ClientHandler의 sock으로 바꾼다.
세 번째.. sending 쓰레드와 blocking queue를 구현하여 sender 를 완벽히 분리해버린다.
이 정도일거 같습니다. 개인적으로는 주로 세번째 방식을 사용해왔었습니다만.. 그 이유는 클라이언트들끼리 서로 상태에 변화를 줄 수 있기 때문이었고, 그렇지 않고 단순히 보내고 땡~ 인 경우엔 첫번째를 주로 썼습니다. 두번째가 아닌 첫번째를 사용한 이유는 Handler가 지 할일 알아서 다 하는게 더 깔끔해 보였기 때문이랄까요? ;]
이 글을 적으면서 발견한 두번째 방식(위 소스코드를 좀 유심히 봤습니다.)이 당장 적용하시기엔 더 편하실듯 싶네요.
※ 2010-06-03 12:39:43 에 "bard(bard)" 에 의해 수정됨
synchronized 구문을 메소드에다 걸어놓으면 해당 메소드에 진입하는 모든 쓰레드는 모니터를 얻어내야 합니다.
즉, 하나의 ClientHander 가 message 를 sending 하기 위해 sender(메소드명을 이렇게 명사로 적는건 안좋습니다. ;])에게 진입하는 순간 다른 ClientHandler 는 이전에 진입한 ClientHandler 가 모니터를 release 하기 전까지는 wait 상태가 되버리죠.
network programming 을 할 때는 synchronized 블럭을 최소화 해야 합니다. 더 안전은 해지겠지만, 동시성은 떨어지게 되고, 자칫 잘못설계된 호출 순서로 인해 deadlock에 빠지기도 하지요..
동시성을 높이는 방법은 여러가지가 있겠습니다만.. 위의 소스에서 보면 clienthandler 간의 interaction 은 거의 없습니다. 따라서 sender 메소드가 synchronized 될 이유는 없는것이죠.
옵션은 두가지가 있습니다. (아니 세가지라고 해야 하나요?)
첫 번째.. 위에서 말씀드렷듯이 ClientHandler 에게 sender 메소드를 줘버린다.
두 번째.. synchronized 구문을 sender 메소드에서 제거하고, clientSocket 을 쓰던 부분을 위에서 말씀드린데로 ClientHandler의 sock으로 바꾼다.
세 번째.. sending 쓰레드와 blocking queue를 구현하여 sender 를 완벽히 분리해버린다.
이 정도일거 같습니다. 개인적으로는 주로 세번째 방식을 사용해왔었습니다만.. 그 이유는 클라이언트들끼리 서로 상태에 변화를 줄 수 있기 때문이었고, 그렇지 않고 단순히 보내고 땡~ 인 경우엔 첫번째를 주로 썼습니다. 두번째가 아닌 첫번째를 사용한 이유는 Handler가 지 할일 알아서 다 하는게 더 깔끔해 보였기 때문이랄까요? ;]
이 글을 적으면서 발견한 두번째 방식(위 소스코드를 좀 유심히 봤습니다.)이 당장 적용하시기엔 더 편하실듯 싶네요.
※ 2010-06-03 12:39:43 에 "bard(bard)" 에 의해 수정됨
2010.06.03 12:38:48 (*.76.115.36)
bard 혹시 Essay es = new Essay(); <- 이놈이 공유자원이고, 내부에 static 메소드들이나 singleton 방식의 구현이 있다면 쓰레드간에 간섭이 발생할 수 있으므로 synchronized 구문을 그냥 제거해 버릴 수는 없겠군요.
이 경우에도 sender 메소드 자체에 synchronized 를 거는건 바람직하지 못합니다. lock 을 최소하 할 수 있도록 Essay 의 메소드 내부에서 synchronized 블럭(메소드의 시그니처로 붙이지 말고..)을 지정해서 사용하세요.
메소드의 시그니처에다 붙이게 되면 Essay 클래스에 접근하는 모든 (물론 synchronized가 붙은 메소드들에 한하여) 호출이 wait 될 수 있습니다.
이 경우에도 sender 메소드 자체에 synchronized 를 거는건 바람직하지 못합니다. lock 을 최소하 할 수 있도록 Essay 의 메소드 내부에서 synchronized 블럭(메소드의 시그니처로 붙이지 말고..)을 지정해서 사용하세요.
메소드의 시그니처에다 붙이게 되면 Essay 클래스에 접근하는 모든 (물론 synchronized가 붙은 메소드들에 한하여) 호출이 wait 될 수 있습니다.
2010.06.03 14:04:22 (*.246.122.200)
녹차한잔 답변 감사드립니다.
synchronized 블럭이 좋은 것만은 아니군요^^;
정말 많은 도움이 되었습니다. 감사합니다
synchronized 블럭이 좋은 것만은 아니군요^^;
정말 많은 도움이 되었습니다. 감사합니다
2013.05.19 11:25:47 (*.153.235.115)
![[레벨:3]](http://old.lameproof.com/modules/point/icons/default/3.gif "포인트:962point (24%), 레벨:3/30"){kind=icon}
bestbasci01@yahoo.com
public synchronized void sender(String message) {
try {
PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream())));
여기가 좀 이상하네요. clientSocket 은 ClientHandler 에 속한 인스턴스 변수가 아닌 서버에 속한 인스턴스 변수인데.. 얘는 현재 구조상 항상 최신의 소켓(제일 마지막에 접속한 소켓)만 유지할 수 있도록 되어있습니다. 따로 ClientHandler 안에 sock 이란 이름으로 해당 클라이언트의 소켓을 유지하고 계시는거 같은데, 그걸 사용하도록 해보세요. sender 에다가 ClientHander의 인스턴스를 인수로 받도록 하면 될듯 싶군요. (근데 sender 라는 메소드는 궂이 ClientHander 에 구현하지 않고 BookServer에 구현한 이유라도 있으신건지 궁금하네요..?)
정리좀 하자면
public synchronized void sender(String message, ClientHandler handler) {
...
PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(handler.sock.getOutputStream())));
...
이런식으로 바꾸고
sender("EDIT");
이렇게 부르는 곳을 줴다
sender("EDIT", this); 혹은 sender("EDIT", ClientHander.this);
이런식으로 바꿔주면 제대로 되지 않을까 싶습니다.
PS: 위에서도 잠깐 얘기했는데, 출력을 궂이 순차적으로 할 이유가 없다면 sender 라는 메소드는 ClientHander가 갖는게 맞을듯 싶네요.. concurrency 측면에서 한번에 하나의 소켓으로 밖에 데이터를 못쏘는 구조라(synchronized 도 걸려있고 해서리..), 별로 좋아보이지 않네요 ^^;