JAVA 채팅 프로그램 소스

클라이언트

import java.awt.BorderLayout;

import java.awt.Button;

import java.awt.TextArea;

import java.awt.TextField;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import java.nio.ByteOrder;

import javax.swing.JFrame;

class MyFrame extends JFrame implements ActionListener

{

public TextField tf;

public TextArea ta;

PrintWriter out;

public MyFrame(PrintWriter out)

{

this.out = out;

tf = new TextField();

ta = new TextArea();

setSize(600, 400);

setVisible(true);

add(tf, BorderLayout.SOUTH);

add(ta, BorderLayout.CENTER);

tf.addActionListener(this);

}

@Override

public void actionPerformed(ActionEvent arg0)

{

if (arg0.getSource() == tf)

{

out.println(tf.getText().toString());

tf.setText("");

}

}

}

public class client

{

public static void main(String[] args)

{

BufferedReader user = new BufferedReader(new InputStreamReader(

System.in));

Socket socket;

try

{

socket = new Socket("115.20.247.142", 1251);

PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

MyFrame mf = new MyFrame(out);

ReceiveThread rt = new ReceiveThread(socket, mf.ta);

rt.start();

} catch (IOException e)

{

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

class ReceiveThread extends Thread

{

Socket socket;

TextArea ta;

public ReceiveThread(Socket socket, TextArea ta)

{

this.socket = socket;

this.ta = ta;

}

@Override

public void run()

{

BufferedReader in;

try

{

in = new BufferedReader(new InputStreamReader(

socket.getInputStream()));

while (true)

{

ta.setText(ta.getText() +"\n"+ in.readLine());

}

} catch (IOException e)

{

// TODO Auto-generated catch block

e.printStackTrace();

}

super.run();

}

}

서버

package com.tansanc.tistory;

import java.io.IOException;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

public class MyApplet2

{

public static void main(String[] args) throws IOException

{

int i = 1;

ServerSocket server = null;

server = new ServerSocket(1251, 5);

while (true)

{

System.out.println("Accept 대기");

Socket socket = server.accept();

System.out.println("Accept 성공");

PerClientReceiveThread pcrt = new PerClientReceiveThread(socket);

pcrt.start();

}

// Socket socket = new Socket("115.20.247.142",1251);

// InputStream is = socket.getInputStream();

// byte i = (byte)is.read();

// System.out.println(i);

}

}

package com.tansanc.tistory;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import java.util.ArrayList;

public class PerClientReceiveThread extends Thread

{

static ArrayList<PrintWriter> arGeneral = new ArrayList<PrintWriter>();

Socket socket;

public PerClientReceiveThread(Socket socket)

{

this.socket = socket;

}

@Override

public void run()

{

InputStream os;

try

{

BufferedReader in = new BufferedReader(new InputStreamReader(

socket.getInputStream()));

PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

arGeneral.add(out);

while (true)

{

String msg = in.readLine();

System.out.println(msg);

for (int i = 0; i < arGeneral.size(); i++)

{

arGeneral.get(i).println(msg);

}

}

} catch (IOException e)

{

// TODO Auto-generated catch block

e.printStackTrace();

}

super.run();

}

}