java 之网络通信

实现服务器与客户端之间的通信功能：

服务端：

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;

public class bb {
	public static void main(String[] args)
	{
		try
		{
			for (int i=1;i<=100;i++)
			{
			Socket s= new Socket("localhost",5000);
			DataInputStream datain =new DataInputStream(s.getInputStream());
			DataOutputStream dataout =new DataOutputStream(s.getOutputStream());
			//BufferedReader in =new BufferedReader(new InputStreamReader(System.in));
			//String x;
			//x=in.readLine();
			//int a=Integer.parseInt(x);
			int a=(int) (Math.random()*1000);
			System.out.println("客户端"+a);
			dataout.writeInt(a);
			System.out.println("服务端"+datain.readInt());
			datain.close();
			dataout.close();
			s.close();
			}	
		}
		catch (Exception e) {
			// TODO: handle exception
			System.out.println("yichang"+e);
			e.printStackTrace();
		}
	}
}

客户端：

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class aa {
	public static void main(String[] args)
	{
		try
		{
			ServerSocket server =null;
			server =new ServerSocket(5000);
			while (true)
			{
				Socket s = server.accept();
				System.out.println("连接成功");
				DataInputStream datain=new DataInputStream(s.getInputStream());
				int a;
				a=datain.readInt();
				DataOutputStream dataout =new DataOutputStream(s.getOutputStream());
				dataout.writeInt(a*2);
				dataout.close();
				datain.close();
				s.close();
			}
		}
		catch (Exception e) {
			// TODO: handle exception
			System.out.println("yichang");
			e.printStackTrace();
		}
	}
}