socket编程范例

项目大量用到了网络通信内容,自己学习了一下.写了一个java Socket实例.还写了比较详细的注释.以方便以后的阅读.代码实现的功能是服务器段打开之后监听一个端口,当有客户端访问该服务器端时,就建立客户端与服务器端的联系.支持多个客户端与服务器进行连接.然后客户端输入信息.服务器可以针对客户端进行回复.

文件一: SocketServer.java        ---->        Socket服务器端

package com.huameng.socket.next;

import java.net.ServerSocket;

/**
 * 服务器端Socket
 *
 * @author Administrator
 *
 */
public class SocketServer {

 /**
  * 服务器端Socket构造方法
  */
 public SocketServer() {
  try {

   int clientcount = 0; // 统计客户端总数

   boolean listening = true; // 是否对客户端进行监听

   ServerSocket server = null; // 服务器端Socket对象

   try {
    // 创建一个ServerSocket在端口2121监听客户请求
    server = new ServerSocket(2121);

    System.out.println("Server starts...");
   } catch (Exception e) {
    System.out.println("Can not listen to. " + e);
   }

   while (listening) {
    // 客户端计数
    clientcount++;

    // 监听到客户请求,根据得到的Socket对象和客户计数创建服务线程,并启动之
    new ServerThread(server.accept(), clientcount).start();
   }
  } catch (Exception e) {
   System.out.println("Error. " + e);
  }
 }

 /**
  * 主方法
  *
  * @param args
  */
 public static void main(String[] args) {
  new SocketServer();
 }
}

 

文件二: ServerThread.java       ---->        服务器监控器

package com.huameng.socket.next;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread extends Thread {

 private static int number = 0; // 保存本进程的客户计数

 Socket socket = null; // 保存与本线程相关的Socket对象

 public ServerThread(Socket socket, int clientnum) {

  this.socket = socket;
  number = clientnum;
  System.out.println("当前在线的用户数: " + number);
 }

 public void run() {
  try {

   // 由Socket对象得到输入流,并构造相应的BufferedReader对象
   BufferedReader in = new BufferedReader(new InputStreamReader(socket
     .getInputStream()));

   // 由Socket对象得到输出流,并构造PrintWriter对象
   PrintWriter out = new PrintWriter(socket.getOutputStream());

   // 由系统标准输入设备构造BufferedReader对象
   BufferedReader sysin = new BufferedReader(new InputStreamReader(
     System.in));

   // 在标准输出上打印从客户端读入的字符串
   System.out.println("[Client " + number + "]: " + in.readLine());

   String line; // 保存一行内容

   // 从标准输入读入一字符串
   line = sysin.readLine();

   while (!line.equals("bye")) { // 如果该字符串为 "bye",则停止循环

    // 向客户端输出该字符串
    out.println(line);

    // 刷新输出流,使Client马上收到该字符串
    out.flush();

    // 在系统标准输出上打印读入的字符串
    System.out.println("[Server]: " + line);

    // 从Client读入一字符串,并打印到标准输出上
    System.out.println("[Client " + number + "]: " + in.readLine());

    // 从系统标准输入读入一字符串
    line = sysin.readLine();
   }

   out.close(); // 关闭Socket输出流
   in.close(); // 关闭Socket输入流
   socket.close(); // 关闭Socket
  } catch (Exception e) {
   System.out.println("Error. " + e);
  }
 }

}

 

文件三: ScoketClient.java        ---->        Scoket客户端

package com.huameng.socket.next;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

/**
 * 客户端Socket
 *
 * @author Administrator
 *
 */
public class SocketClient {

 /**
  * 客户端Socket构造方法
  */
 public SocketClient() {
  try {

   // 向本机的2121端口发出客户请求
   Socket socket = new Socket("localhost", 2121);

   System.out.println("Established a connection...");

   // 由系统标准输入设备构造BufferedReader对象
   BufferedReader sysin = new BufferedReader(new InputStreamReader(
     System.in));

   // 由Socket对象得到输出流,并构造PrintWriter对象
   PrintWriter out = new PrintWriter(socket.getOutputStream());

   // 由Socket对象得到输入流,并构造相应的BufferedReader对象
   BufferedReader in = new BufferedReader(new InputStreamReader(socket
     .getInputStream()));

   String line; // 保存一行内容

   // 从系统标准输入读入一字符串
   line = sysin.readLine();

   while (!line.equals("bye")) { // 若从标准输入读入的字符串为 "bye"则停止循环

    // 将从系统标准输入读入的字符串输出到Server
    out.println(line);

    // 刷新输出流,使Server马上收到该字符串
    out.flush();

    // 在系统标准输出上打印读入的字符串
    System.out.println("[Client]: " + line);

    // 从Server读入一字符串，并打印到标准输出上
    System.out.println("[Server]: " + in.readLine());

    // 从系统标准输入读入一字符串
    line = sysin.readLine();

   }

   out.close(); // 关闭Socket输出流
   in.close(); // 关闭Socket输入流
   socket.close(); // 关闭Socket
  } catch (Exception e) {
   System.out.println("Error. " + e);
  }
 }

 /**
  * 主方法
  *
  * @param args
  */
 public static void main(String[] args) {
  new SocketClient();
 }

}