【JAVA】基于Socket协议传输的服务端与客户端实例！(可直接运行)

一、Socket_Server.java

package socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;

public class Socket_Server {

	public static void main(String[] args) {
		
		try{

			// 创建一个服务器端对象m_ServerSocket,参数是端口号
			ServerSocket m_ServerSocket=new ServerSocket(5000);
			
			// 通过accept（）接收客户的通信
			Socket m_socket=m_ServerSocket.accept();
			
			// 获取客户端输入流，获得用户请求的信息
			InputStream is=m_socket.getInputStream();
			BufferedReader br=new BufferedReader(new InputStreamReader(is));
			String info;
			while((info=br.readLine())!=null){
				System.out.println("客户端说："+info);
			}
			
			// 给客户端传一个响应字符
			String reply="来自【服务器】的信息：作者是【老舍】。";
			byte[] replys=reply.getBytes();
			// 通过输出流发送请求
			OutputStream os=m_socket.getOutputStream();
			os.write(replys);
			
			// 关闭打开的资源
			os.close();
			br.close();
			is.close();
			m_socket.close();
			m_ServerSocket.close();
		}
		catch (UnknownHostException e)
		{
			e.printStackTrace();
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
		
		
	}
	
	
	
}

 

 

 

二、Socket_Client.java

 

package socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Socket_Client {

	public static void main(String[] args) {
	
		try{

			// 创建一个客户端对象m_socket,参数是地址和端口号
			Socket m_socket=new Socket("localhost",5000);
			
			// 通过输出流发送请求
			OutputStream os=m_socket.getOutputStream();
			// 把信息存入到字节变量中，再发送。
			String info="服务器，帮我查一下《骆驼祥子》的作者是谁？";
			byte[] infos=info.getBytes();
			os.write(infos);

			// 先关闭socket连接
			 m_socket.shutdownOutput();

			InputStream is=m_socket.getInputStream();
			BufferedReader br=new BufferedReader(new InputStreamReader(is));
			String reply;
			while((reply=br.readLine())!=null){
				System.out.println("服务器的响应："+reply);
			}
			
			
			// 关闭打开的资源
			br.close();
			is.close();
			os.close();
			m_socket.close();
			
		}
		catch (UnknownHostException e)
		{
			e.printStackTrace();
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
		
		
	}

}