양방향채팅

import java.net.*;
import java.io.*;
import java.util.*;

class Server extends Thread{
BufferedReader br=null;
BufferedWriter bw=null;
Scanner sc=null;
Server() throws Exception{
ServerSocket ss=new ServerSocket(8888);
Socket s=ss.accept();
InputStream is=s.getInputStream();
OutputStream os=s.getOutputStream();

InputStreamReader isr=new InputStreamReader(is);
br=new BufferedReader(isr);

OutputStreamWriter osw=new OutputStreamWriter(os);
bw=new BufferedWriter(osw);

sc=new Scanner(System.in);
}
void sendMsg() throws Exception{
while(true){
bw.write(sc.nextLine()+"\n");
bw.flush();}
}
public void run(){
try{
while(true){
String line=br.readLine();
System.out.println(line);
}
}catch(Exception e){ System.out.println("읽다가에러남~"); }
}
public static void main(String args[]) throws Exception{
Server server=new Server();
server.start();
server.sendMsg();
}
}

 

 

import java.net.*;
import java.io.*;
import java.util.*;

class Client extends Thread {
 BufferedReader br = null;
 BufferedWriter bw = null;
 Scanner sc = null;

 Client() throws Exception {
  Socket ss = new Socket("192.168.1.163",7777);
  InputStream is = ss.getInputStream();
  OutputStream os = ss.getOutputStream();

  InputStreamReader isr = new InputStreamReader(is);
  br = new BufferedReader(isr);

  OutputStreamWriter osw = new OutputStreamWriter(os);
  bw = new BufferedWriter(osw);

  sc = new Scanner(System.in);
 }

 void sendMsg() throws Exception {
  while (true) {
   bw.write(sc.nextLine()+"\n");
   bw.flush();
  }
 }

 public void run() {
  try {
   while (true) {
    String line = br.readLine();
    System.out.println(line);
   }
  } catch (Exception e) {
   System.out.println("읽다가에러남~");
  }
 }

 public static void main(String args[]) throws Exception {
  Client client = new Client();
  client.start();
  client.sendMsg();
 }
}