java之Scoket 客户端和服务器的发送与接收

    什么是socket

　　 所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。

　　 以JDK-1.6为例，Socket和ServerSocket类库位于java.net包中。ServerSocket用于服务器端，Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例，操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别，不因为在服务器端或在客户端而产生不同级别。不管是Socket还是ServerSocket它们的工作都是通过SocketImpl类及其子类完成的。

　　 重要的Socket API：

　　 java.net.Socket继承于java.lang.Object，有八个构造器，其方法并不多，下面介绍使用最频繁的三个方法，其它方法大家可以见JDK-1.6文档。

　　 . Accept方法用于产生"阻塞"，直到接受到一个连接，并且返回一个客户端的Socket对象实例。"阻塞"是一个术语，它使程序运行暂时"停留"在这个地方，直到一个会话产生，然后程序继续；通常"阻塞"是由循环产生的。

　　 . getInputStream方法获得网络连接输入，同时返回一个IutputStream对象实例，。

　　 . getOutputStream方法连接的另一端将得到输入，同时返回一个OutputStream对象实例。

　　 注意：其中getInputStream和getOutputStream方法均会产生一个IOException，它必须被捕获，因为它们返回的流对象，通常都会被另一个流对象使用。

客户端和服务器端通过socket发送消息和接收消息的过程：
接收消息的过程

发送消息的过程




客户端：

package com.jysd.client;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

	public void go() throws UnknownHostException, IOException{
		
		//向服务器端发送请求，服务器IP地址和服务器监听的端口号
		Socket client = new Socket("127.0.0.1", 4242);
		
                  //通过printWriter 来向服务器发送消息
		PrintWriter printWriter = new PrintWriter(client.getOutputStream());
		System.out.println("连接已建立...");
                  
                  //发送消息
		printWriter.println("hello Server");
		
		printWriter.flush();
		
		//InputStreamReader是低层和高层串流之间的桥梁
		//client.getInputStream()从Socket取得输入串流
		InputStreamReader streamReader = new InputStreamReader(client.getInputStream());
		
		//链接数据串流，建立BufferedReader来读取，将BufferReader链接到InputStreamReder
		BufferedReader reader = new BufferedReader(streamReader);
		String advice =reader.readLine();
		
		
		System.out.println("接收到服务器的消息 ："+advice);
		reader.close();
	}
	
	public static void main(String[] args) throws UnknownHostException, IOException {
		Client c = new Client();
		c.go();
	}
}

服务器端：

package com.jysd.server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;


public class Server {
	

	private ServerSocket ss;
	
	private InputStreamReader inputStreamReader; 
	
	private BufferedReader bufferedReader;
	
	public void server(){

		try {
			//让服务器端程序开始监听来自4242端口的客户端请求
			if (ss==null) {
				 ss = new ServerSocket(4242);
				 System.out.println("服务器启动...");
			}
			
			//服务器无穷的循环等待客户端的请求
			while(true){	
			/*
			 *accept()方法会在等待用户的socket连接时闲置着，当用户链接
			 *上来时，此方法会返回一个socket(在不同的端口上)以便与客户端
			 *通信。Socket与ServerSocket的端口不同，因此ServerSocket可以
			 *空闲出来等待其他客户端
			 */
			//这个方法会停下来等待要求到达之后再继续
			Socket s = ss.accept();
			
			inputStreamReader = new InputStreamReader(s.getInputStream());
			bufferedReader = new BufferedReader(inputStreamReader);
			
			String request = bufferedReader.readLine();

			System.out.println("接收到了客户端的请求:"+request);
			PrintWriter printWriter = new PrintWriter(s.getOutputStream());
			
			String advice = "I am Server";
			printWriter.println(advice);
			printWriter.close();
			
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}
	
	public static void main(String[] args) {
		Server server = new Server();
		server.server();
	}
	
	
}