Socket 学习笔记(三)补充关于Socket双向输入输出的例子

前面几章的例子中服务端收到信息后都没有返回应答信息，在实际中也许会有用到，写个例子记住

服务端代码

package com.mytest.socket;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SocketSevice {

	//侦听端口
	private  int port;
	
	private  ServerSocket serverSocket;
	
	//最大连接
	private static  int maxCount=3;
	
	//连接数量累计
	private  int index=0;
	
	private static  SocketSevice socketSevice=new SocketSevice(); 
	
	//任务线程池
	private  ExecutorService threadPool=Executors.newFixedThreadPool(maxCount);
	
	private SocketSevice(){}
	
	public static SocketSevice getInstance() 
	{
	
		return socketSevice;
	}
	
	public void listening(int port) throws IOException
	{
		this.port=port;
		serverSocket=new ServerSocket(port);
		
		//使用accept()阻塞等待客户请求，有客户请求到来则产生一个Socket对象，并继续执行
		while(true){	
		    Socket socket=serverSocket.accept();
		     SocketTask task=new SocketTask(socket,"任务"+index);
			 threadPool.execute(task);
			 index++;
		    
		   
		}
		
		
	}
	
	public void shutdown() throws IOException
	{
		if(threadPool.isTerminated()){
		  threadPool.shutdown();
		  serverSocket.close();
		}
	}
	
	public static void main(String[] args) 
	{
		SocketSevice s=SocketSevice.getInstance();
		
		try {
			s.listening(1099);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}
	
	
	public int getPort() {
		return port;
	}

	public void setPort(int port) {
		this.port = port;
	}
	
	
	
}

package com.mytest.socket;

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;

public class SocketTask implements Runnable{

	private Socket socket;
	private String name;
	
	public SocketTask(Socket socket,String name)
	{
		this.socket=socket;
		this.name=name;
		System.out.println("["+name+"]"+"开始.....");
	}
	
	@Override
	public void run() {
		
		BufferedReader br =null;
		BufferedWriter bw=null;
	try {
		
		 br=new BufferedReader(new InputStreamReader(socket.getInputStream()));  
         String  msg= br.readLine();  
         bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
         System.out.println("["+name+"]"+"接收数据>>"+msg);
         String str = "当前处理["+msg+"]";  
         bw.write(str);  
         bw.flush();  
         System.out.println("推送["+name+"]应答信息\n");
	} catch (IOException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}finally
	{
		try {
			if(br!=null)
			{
				br.close();
			}
			if(bw!=null)
			{
				bw.close();
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
			
	}
		
	
		
		
	}

}

客户端的具体代码

package com.mytest.socket;

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.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class SocketClient {
	
	private int remotePort;
	private String remoteIp;
	private Socket socket;
	
	public SocketClient(String remoteIp,int remotePort) throws IOException
	{
		this.remoteIp=remoteIp;
		this.remotePort=remotePort;
		socket=new Socket(remoteIp,remotePort);
		System.out.println("连接 : "+remoteIp+" : "+remotePort);
		
	}
	
	
	
    public void close() throws IOException
    {
    	socket.close();
    	System.out.println(" ----关闭连接 ----\n");
    }
	
	public void writeString(String str) throws IOException
	{
		//构建IO流  
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
		
		bw.write(str);
		
		//当接收的类使用的是BufferedReader，发送的类是BufferedWriter的时候，要注意发送的一行要有换行标识符才能正确写入
		
		bw.newLine();
		//刷新缓冲区才能真正写入
		bw.flush();
		System.out.println("传送数据: "+str);

        //读取服务器返回的消息数据  
		
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
	    String callbrk=br.readLine();
        System.out.println(socket.getInetAddress().getLocalHost()+":"+socket.getPort()+">>"+callbrk); 
        
		
		 
		 
	}
	
	

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		
		try {
			for(int i=0;i<5;i++){
			SocketClient client=new SocketClient("127.0.0.1",1099);
			client.writeString("哈哈哈"+i);
			
			client.close();
			
			}
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
   
	}

}

先运行服务端（SocketSevice），再运行客户端(SocketClient) 效果如下