java网络编程 多线程服务器与客户端系统架构 socket应用

    java网络编程 多线程服务器与客户端系统架构 socket应用

    最近在做一些金融业管理系统，经常要进行网络间数据的交互，其实也就是服务器端与客户端的一些信息发送与接收。系统已经完成，也就整理下使用的架构。

    服务器端：做为系统的服务器是要面对多个客户端的，所以要用多线程来架设，对每个客户端的数据处理都是互不影响的，而且服务器与客户端的数据交互是同步的。

    客户端：客户端的应用也就是发送信息到服务器，然后得到服务器返回的信息。

   （代码很清晰，就不用多说了。）

   服务器端主要有三个类：

      1、服务器类：Server.java

      2、服务器线程类：ServerThread.java

      3、服务器代理线程类：ServerThreadAgent.java

    客户端主要有两个类：

       1、信息发送类：Client.java

       2、信息接收类：ClientThreadAgent.java

package net.xiaoxiang.socket; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; /** * @author weishaoxiang */ public class Server { ServerSocket serverSocket; ServerThread serverThread; boolean sign = true; // true：服务器未启动 false：服务器已启动 public static void main ( String[] args ) { Server server = new Server ( ); try { server.showmenu ( ); while ( true ) { InputStreamReader reader = new InputStreamReader ( System.in ); BufferedReader br = new BufferedReader ( reader ); String chooce = br.readLine ( ); if ( "0".equals ( chooce ) ) server.exitSystem ( ); if ( "1".equals ( chooce ) ) server.startServer ( ); if ( "2".equals ( chooce ) ) server.stopServer ( ); if ( "3".equals ( chooce ) ) server.showmenu ( ); } } catch ( Exception e ) { e.printStackTrace ( ); } } public void startServer ( ) { if ( sign == true ) { try { serverSocket = new ServerSocket ( 8888 ); serverThread = new ServerThread ( serverSocket ); serverThread.start ( ); sign = false; System.out.println ( "\n 服务器--启动成功。\n" ); } catch ( IOException e ) { System.out.println ( "\n 服务器--启动失败！\n" ); } } else { System.out.println ( "\n 服务器--已经启动" ); } } public void stopServer ( ) { if ( sign == false ) { try { if ( serverThread != null ) { serverThread.flag = false;// 关闭服务器线程 serverThread.serverSocket.close ( ); serverThread = null; } this.serverSocket.close ( ); sign = true; System.out.println ( "服务器--关闭成功" ); } catch ( IOException e ) { System.out.println ( "服务器关闭出现异常！" ); e.printStackTrace ( ); } } else { System.out.println ( "服务器--未启动" ); } } public void exitSystem ( ) { this.stopServer ( ); System.out.println ( "服务器线程关闭----退出程序" ); System.exit ( 0 ); } public void showmenu ( ) { System.out.println ( " 服务器菜单" ); System.out.println ( " 请选择输入相应菜单对应的标号" ); System.out.println ( " 1 启动服务器" ); System.out.println ( " 2 关闭服务器" ); System.out.println ( " 3 显示菜单" ); System.out.println ( " 0 关闭程序" ); } }

 

 

package net.xiaoxiang.socket; import java.net.ServerSocket; import java.net.Socket; /** * @author weishaoxiang */ public class ServerThread extends Thread { ServerSocket serverSocket; boolean flag = true; public ServerThread( ServerSocket serverSocket ){ this.serverSocket = serverSocket; } public void run( ){ while( flag ){ try{ Socket socket = serverSocket.accept( ); ServerThreadAgent serverThreadAgent = new ServerThreadAgent( socket ); serverThreadAgent.start( ); } catch( Exception e ){ e.printStackTrace( ); } } } }

 

package net.xiaoxiang.socket; import java.net.Socket; import net.xiaoxiang.utils.SocketUtil; /** * @author weishaoxiang */ public class ServerThreadAgent extends Thread { Socket socket; public ServerThreadAgent ( Socket socket ){ this.socket = socket; } /** * 在代理线程中进行业务处理 */ public void run ( ) { try { byte[] message = SocketUtil.readStream ( socket );// 接收信息 System.out.println ( socket.getInetAddress ( ) + "发来信息:" + new String ( message, "GBK" ) ); /* 在此处就可以进行自己的业务处理 */ String sendMessage = "信息已经收到。"; SocketUtil.writeStream ( sendMessage.getBytes ( ), socket );// 发送信息 } catch ( Exception e ) { e.printStackTrace ( ); } } }

 

package net.xiaoxiang.socket; import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.Socket; import net.xiaoxiang.utils.SocketUtil; /** * @author weishaoxiang */ public class Client { Socket socket; ClientThreadAgent clientThreadAgent; boolean sign = true; public static void main ( String[] args ) { Client client = new Client ( ); InputStreamReader reader = new InputStreamReader ( System.in ); BufferedReader br = new BufferedReader ( reader ); try { client.showmenu ( ); while ( true ) { String menu = br.readLine ( ); if ( "0".equals ( menu ) ) { client.exitSystem ( ); continue; } if ( "1".equals ( menu ) ) { client.showmenu ( ); continue; } if ( "2".equals ( menu ) ) { for ( int i = 0; i < 100; i++ ) client.send ( "发送第 " + i + " 条信息" ); continue; } System.out.println ( "输入错误！请查看菜单：3" ); } } catch ( Exception e ) { e.printStackTrace ( ); } } private void showmenu ( ) { System.out.println ( " 系统菜单" ); System.out.println ( " 请选择输入相应菜单对应的标号" ); System.out.println ( " 1-------显示菜单" ); System.out.println ( " 0-------关闭程序" ); System.out.println ( " 2----发送信息" ); } private void exitSystem ( ) { try { System.out.println ( "程序已经关闭。" ); System.exit ( 0 ); } catch ( Exception e ) { e.printStackTrace ( ); } } private void startClientServer ( ) { try { socket = new Socket ( "127.0.0.1", 8888 ); clientThreadAgent = new ClientThreadAgent ( socket ); clientThreadAgent.start ( ); } catch ( Exception ee ) { ee.printStackTrace ( ); } } private void send ( String message ) { this.startClientServer ( ); SocketUtil.writeStream ( message.getBytes ( ), socket );// 发送信息 } }

 

package net.xiaoxiang.socket; import java.net.Socket; import net.xiaoxiang.utils.SocketUtil; /** * @author weishaoxiang */ public class ClientThreadAgent extends Thread { Socket socket; public ClientThreadAgent ( Socket socket ){ this.socket = socket; System.out.println ( "连接服务器成功 IP: " + socket.getInetAddress ( ) + " 端口：" + socket.getPort ( ) ); } public void run ( ) { try { byte[] message = SocketUtil.readStream ( socket );// 接收信息 System.out.println ( new String ( message, "GBK" ) ); socket.close ( ); } catch ( Exception e ) { e.printStackTrace ( ); } } }