[JAVA] TCP 1:1 채팅

TCP 1 : 1 채팅

Class TcpChatServer

 
 
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
 
public class TcpChatServer {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket socket = null;
 
        try {
            serverSocket = new ServerSocket(5000);
            socket = serverSocket.accept();
 
            TcpSendThread sender = new TcpSendThread(socket);
            TcpReceiverThread receiver = new TcpReceiverThread(socket);
 
            Thread t1 = new Thread(sender);
            Thread t2 = new Thread(receiver);
 
            t1.start();
            t2.start();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
    }
}
 
 
 

---

Class TcpChatClient

 
 
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
 
public class TcpChatClient {
    public static void main(String[] args) {
 
        Socket socket = null;
        String ip;
        String name;
        Scanner scan = new Scanner(System.in);
 
        System.out.println("ip를 입력하세요.");
        ip = scan.nextLine();
 
        try {
            socket = new Socket(ip, 5000);
            TcpSendThread sender = new TcpSendThread(socket);
            TcpReceiverThread receiver = new TcpReceiverThread(socket);
 
            Thread t1 = new Thread(sender);
            Thread t2 = new Thread(receiver);
 
            t1.start();
            t2.start();
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
    }
}
 
 

---

Class TcpSenderThread

 
 
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;
 
public class TcpSendThread implements Runnable {
 
    Socket socket;
    BufferedWriter bw = null;
    String msg;
    String name;
    Scanner scan = new Scanner(System.in);
 
    public TcpSendThread(Socket socket) {
        this.socket = socket;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    @Override
    public void run() {
        // TODO Auto-generated method stub
        try {
            bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            // System.out.println("이름을 입력하세요");
            // name = scan.nextLine();
 
            while (true) {
                msg = scan.nextLine();
                bw.write(name + " : " + msg + "\n");
                bw.flush();
            }
 
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
    }
 
}
 
 
 

---

Class TcpReceiverThread

 
 
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
 
public class TcpReceiverThread implements Runnable {
    Socket socket;
    BufferedReader br = null;
    String msg;
    String name;
 
    public TcpReceiverThread(Socket socket) {
        this.socket = socket;
    }
 
    @Override
    public void run() {
        // TODO Auto-generated method stub
        try {
 
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
 
            while (true) {
                msg = br.readLine();
                System.out.println(msg);
 
                if (msg.equals("quit"))
                    break;
            }
 
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
    }
 
}