serversocketdemo.java

java scoket通信的源程序

import java.net.*;
import java.io.*;
public class ServerSocketDemo 
{
	//声明ServerSocket类对象
    ServerSocket serverSocket;
    
    //声明并初始化服务器端监听端口号常量
    public static final int PORT = 10745;
    
    //声明服务器端数据输入输出流
    DataInputStream in;
    DataOutputStream out;
    
    //声明InetAddress类对象ip，用于获取服务器地址及端口号等信息
    InetAddress ip = null; 
    
    //声明字符串数组对象request，用于存储从客户端发送来的信息
    String request[];
    
	public ServerSocketDemo()
	{
		request = new String[3]; //初始化字符串数组
        try
        {
        	//获取本地服务器地址信息
    		ip = InetAddress.getLocalHost();
    		
    		//以PORT为服务端口号，创建serverSocket对象以监听该端口上的连接
            serverSocket = new ServerSocket(PORT);
            
            //创建Socket类的对象socket，用于保存连接到服务器的客户端socket对象
            Socket socket = serverSocket.accept();
            System.out.println("This is server:"+String.valueOf(ip)+PORT);
            
            //创建服务器端数据输入输出流，用于对客户端接收或发送数据
            in = new DataInputStream(socket.getInputStream());
            out = new DataOutputStream(socket.getOutputStream());
            
            //接收客户端发送来的数据信息，并显示
            request[0] = in.readUTF();
            request[1] = in.readUTF();
            request[2] = in.readUTF();
            System.out.println("Received messages form client is:");
            System.out.println(request[0]);
            System.out.println(request[1]);
            System.out.println(request[2]);
            
            //向客户端发送数据
            out.writeUTF("Hello client!");
            out.writeUTF("Your ip is:"+request[1]);
            out.writeUTF("Your port is:"+request[2]);
        }
        catch(IOException e){e.printStackTrace();}
	}
	public static void main(String[] args) 
	{
		ServerSocketDemo demo = new ServerSocketDemo();
	}
}