messageserver.java

java 通讯程序

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;

public class MessageServer {

	public static void main(String[] args) {
		String bindAddr=null;
		int bindPort=0;
		if(args.length==2){
			bindAddr=args[0];
			try{
				bindPort=Integer.parseInt(args[1]);
			}catch(Exception e){
				System.out.println("参数错误：断口号必须是1024~65535之间的整数");
				System.out.println("用法：java MessageClient <地址> <端口号>");
				System.exit(-1);
			}
		}else{
			System.out.println("用法：java MessageServer <地址> <端口号>");
			System.exit(-1);
		}
		InetAddress serverAddr=null;
		try {
			serverAddr = InetAddress.getByName(bindAddr);
		} catch (UnknownHostException e) {
			System.out.println("地址错误：服务器地址错误");
			System.out.println("用法：java MessageClient <地址> <端口号>");
			System.exit(-1);
		}
		ServerSocket server=null;
		Socket session=null;
		try {
			server=new ServerSocket(bindPort,20,serverAddr);
			System.out.println("信息：服务器启动成功，开始监听");
			session=server.accept();
			DataInputStream dis=new DataInputStream(session.getInputStream());
			DataOutputStream dos=new DataOutputStream(session.getOutputStream());
			String message=dis.readUTF();
			dos.writeUTF("接收到的消息: "+message);
			System.out.println("信息：服务器发回响应，正常关闭");
		} catch (IOException e) {
			System.out.println("通信错误：在与服务器通信过程中发生错误");
			System.exit(-1);
		} finally{
			try {
				session.close();
			} catch (IOException e) {}
		}
	}

}