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{ServerSocketserverSocket;ServerThreadserverThread;booleansign= 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{Socketsocket;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{Socketsocket;ClientThreadAgentclientThreadAgent;booleansign= 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{Socketsocket;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 ( );}}}?
?
?