server.java

一个JAVA的SOCKET例子

package socket;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String args[]) {
        ServerSocket server;
        Socket socket;
        String s;
        InputStream Is;
        OutputStream Os;
        PrintStream PS;

        try {
            // 在端口4321注册服务
            server = new ServerSocket(4321);
            socket = server.accept();// 监听窗口,等待连接

            System.out.println("server ok");
            System.out.println("************************************************");
            // 获得对应Socket的输入/输出流
            Is = socket.getInputStream();
            Os = socket.getOutputStream();
            // 建立数据流
            BufferedReader clientInput = new BufferedReader(
                    new InputStreamReader(Is));
            PS = new PrintStream(Os);
            //DataInputStream in = new DataInputStream(System.in);
            BufferedReader serverInput = new BufferedReader(
                    new InputStreamReader(System.in));
            while (true) {
                s = clientInput.readLine(); // 读入从client传来的字符串
                if (s.trim().equalsIgnoreCase("Bye")) {
                    break; // 如果是"BYE",就退出
                }
                System.out.print("You Say:");
                s = serverInput.readLine(); // 读取用户输入的字符串
                PS.println(s); // 将读取得字符串传给client
                if (s.trim().equalsIgnoreCase("Bye")) {
                    break; // 如果是"BYE",就退出
                }

            }

            // 关闭连接
            //DIS.close(); // 关闭数据输入流
            PS.close(); // 关闭数据输出流
            Is.close(); // 关闭输入流
            Os.close(); // 关闭输出流
            socket.close(); // 关闭sockey
        } catch (Exception e) {
            System.out.println("Error:" + e);
        }
    }

}