码迷,mamicode.com
首页 > 其他好文 > 详细

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

时间:2016-04-26 17:37:29      阅读:192      评论:0      收藏:0      [点我收藏+]

标签:

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("^-^ 服务端已开启 ^-^\r\n");
			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("来自客户端的消息 :\r\n"+str +"\r\n\t"+ 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();
				}
			}
		}	
	}	
}

  

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

标签:

原文地址:http://www.cnblogs.com/deny-66/p/5435695.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!