글쓴이 :윤덕준 1999년 7월 15일 00:44:30
In Reply to: [답변]Multi-Chatting 프로그램의 동작 posted by 조신제 on 1999년 7월 13일 17:37:31:
참고 하세요.
이거 올려도 되려나 모르겠네요... 마소.Jr 4월호에 실렸던 예제입니다.
[ 서버측 소스 ]
/**
* BroadcastServer.java
* Copyright (c) 1998 Yoon Kyung Koo. All rights reserved.
*
* First release date 1998/10/07
*
* @version 1.1 1999/03/08
* @author <A HREF="mailto:yoonforh@nuri.net">Yoon Kyung Koo</A>
*/
import java.io.*;
import java.net.*;
import java.util.*;
class BroadcastServer
{
final static int PORT = 8001;
ServerSocket server = null;
Vector clients = new Vector();
// inner class
class Client extends Thread {
Socket socket = null;
BufferedReader in = null;
PrintWriter out = null;
// constructor
Client (Socket socket) throws IOException {
this.socket = socket;
this.in =
new BufferedReader(
new InputStreamReader(socket.getInputStream()));
this.out =
new PrintWriter(
new OutputStreamWriter(socket.getOutputStream()),
true /* auto flush */);
start(); // run this client thread
}
public void run() {
try {
while (true) {
// note that readLine() is a blocking operation
String line = in.readLine();
if (line == null) { // null means End Of Stream
close();
break;
}
System.out.println(getName()+':'+line);
BroadcastServer.this.broadcast(line);
}
} catch (IOException ie) {
System.err.println(getName()+":IOException. "+ie.getMessage());
close();
}
}
public void close() {
synchronized (BroadcastServer.this) {
try { if (in!=null) in.close(); } catch (Exception e) {}
if (out!=null) out.close();
try { if (socket!=null) socket.close(); } catch (Exception e) {}
socket=null;
}
}
}
// constructor
public BroadcastServer() {
// first, create server socket
try {
server = new ServerSocket(PORT);
} catch (IOException ie) {
System.err.println("Cannot create server socket");
System.exit(1);
}
while (true) {
try {
Socket socket = server.accept();
// add new client to client list
Client client = new Client(socket);
synchronized (this) {
clients.addElement(client);
}
} catch (IOException ie) {
System.err.println("IOException :"+ie.getMessage());
}
}
}
public static void main(String args[]) {
new BroadcastServer();
}
private synchronized void broadcast(String message) {
for (Enumeration enum=clients.elements();
enum.hasMoreElements(); )
{
Client client = (Client) enum.nextElement();
if (client == null)
continue;
if (client.socket == null) { // if closed socket
clients.removeElement(client);
continue;
}
client.out.println(message);
if (client.out.checkError()) { // check error
System.err.println("Error while sending message.");
client.close();
}
}
}
}
[ 애플릿 소스]
/**
* BroadcastApplet.java
* Copyright (c) 1998 Yoon Kyung Koo. All rights reserved.
*
* First release date 1998/10/07
*
* @version 1.0b 1999/03/12
* @author <A HREF="mailto:yoonforh@nuri.net">Yoon Kyung Koo</A>
*/
import java.awt.*;
import java.awt.event.*;
import java.applet.*;
import java.net.*;
import java.io.*;
public class BroadcastApplet extends Applet
implements ActionListener
{
int port;
String host;
TextField inputField;
TextArea outputArea;
Socket socket;
BufferedReader in;
PrintWriter out;
Thread readingThread;
public void init() {
inputField = new TextField();
outputArea = new TextArea();
setLayout(new BorderLayout());
add(inputField, "North");
add(outputArea, "Center");
String param=getParameter("PORT");
if (param==null)
port = 8001; // default port
else
port = Integer.parseInt(param);
host=getParameter("HOST");
if (host==null) // default host is applet's host
host = getCodeBase().getHost();
inputField.addActionListener(this);
doLayout();
}
public void start() {
if (socket == null)
connect();
readingThread = new Thread() {
public void run() {
if (socket == null)
return;
while (socket!=null &&
readingThread==Thread.currentThread()) {
try {
String line = in.readLine();
appendLine(line);
} catch (IOException ie) {
appendLine("IOException:"+ie.getMessage());
closeSocket();
}
}
}
};
readingThread.start();
}
public void stop() {
readingThread=null;
closeSocket();
}
public void actionPerformed(ActionEvent ae) {
if (ae.getSource() instanceof TextField) {
String line = inputField.getText();
inputField.setText(""); // clear text
if (socket == null)
return;
try {
out.println(line);
if (out.checkError())
throw new IOException("Print error.");
} catch (IOException ie) {
closeSocket();
}
}
}
public void connect() {
try {
socket = new Socket(host, port);
in = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(
new OutputStreamWriter(socket.getOutputStream()),
true /* auto flush */);
appendLine("Connected...");
} catch (UnknownHostException uhe) {
appendLine("Unknown host:"+uhe.getMessage());
} catch (IOException ie) {
appendLine("IOException:"+ie.getMessage());
}
}
public synchronized void closeSocket() {
try { if (in != null) in.close(); } catch (Exception e) {}
if (out != null) out.close();
try { if (socket != null) socket.close(); } catch (Exception e) {}
socket = null;
}
public synchronized void appendLine(String message) {
outputArea.append(message+"\n");
}
}