使用socket实现简单的聊天功能

package net;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;

public class SocketTask {

	@SuppressWarnings("resource")
	public static void main(String[] args) {
		//客户端
		Socket s = null;
		try {
			s = new Socket("127.0.0.1", 10086);
			OutputStream output = s.getOutputStream();
			OutputStreamWriter osw = new OutputStreamWriter(output);
			BufferedWriter bw = new BufferedWriter(osw);
			
			Scanner can = new Scanner(System.in);
			String string = can.next();
			bw.write(string);
			bw.flush();
			System.out.println("发送完成........");
			s.shutdownOutput();
			
			InputStream input = s.getInputStream();
			InputStreamReader in = new InputStreamReader(input);
			BufferedReader br = new BufferedReader(in);
			System.out.println(br.readLine());
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			if(s != null){
				try {
					s.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
		
	}
	
}

　　

package net;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Scanner;

public class ServerTask {
	//服务端
	public static void main(String[] args) {
		ServerSocket ss = null;
		BufferedWriter bw = null;
		Date date = new Date();
		SimpleDateFormat simp = new SimpleDateFormat("yyyy年 MM月 H点  mm分 ss秒");
		String time = simp.format(date);			
		try {
			ss = new ServerSocket(10086);
			while(true){
			System.out.println("^-^ 服务端已开启 ^-^
");
			Socket socket = ss.accept();//监听客户端发送的socket对象，在接收到客户端请求之前处于阻塞状态
			
			InputStream is = socket.getInputStream();//从socket中读取传输的内容
			InputStreamReader isr = new InputStreamReader(is);
			BufferedReader br = new BufferedReader(isr);
			
			File file = new File("f:\net.txt");
			bw = new BufferedWriter(new FileWriter(file,true));
		
			String str = null;
			while((str = br.readLine())!= null){
				if(file.exists()){
					file.mkdirs();	
					bw.write(str);
					bw.newLine();
					bw.flush();
				}
				System.out.println("来自客户端的消息 :
"+str +"
	"+ time);
			}
			
			OutputStream output = socket.getOutputStream();
			BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output));
			
			@SuppressWarnings("resource")
			Scanner can = new Scanner(System.in);
			String string = can.next();
			writer.write(string); 
			writer.flush();
			
			socket.shutdownInput();
		} 			
		}catch (IOException e) {
			e.printStackTrace();
		}finally{
			if(ss != null){
				try {
					ss.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}	
	}	
}