zoukankan      html  css  js  c++  java
  • Socket和多线程ServerSocket

    Socket端:

    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;

    public class ClientBank {
        
        private static String ip = "127.0.0.1";
        private static int port = 9090;
        private static Socket client = null;
        
        public String sendLoginSalesmanDom(String dom)throws Exception{
            String domXml = null;
            try {
                client = new Socket(ip,port);
                
                InputStream in = client.getInputStream();
                DataInputStream dataInput = new DataInputStream(in);
                
                OutputStream out = client.getOutputStream();
                DataOutputStream dataOut = new DataOutputStream(out);
                
                dom = "sale00" + dom;
                dataOut.writeUTF(dom);
                domXml = dataInput.readUTF();
                in.close();
                dataInput.close();
                out.close();
                dataOut.close();
                client.close();
                return domXml;
            } catch (UnknownHostException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return domXml;
        }
        
        public String sendAndReturnRecardDom(String dom){
            String domXml = null;
            try {
                client = new Socket(ip,port);
                
                InputStream in = client.getInputStream();
                DataInputStream dataInput = new DataInputStream(in);
                
                OutputStream out = client.getOutputStream();
                DataOutputStream dataOut = new DataOutputStream(out);
                
                dom = "reca01" + dom;
                
                dataOut.writeUTF(dom);
                domXml = dataInput.readUTF();
                in.close();
                dataInput.close();
                out.close();
                dataOut.close();
                client.close();
                return domXml;
            } catch (UnknownHostException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return domXml;
        }

    }

    多线程ServerSocket:

    import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;

    public class ServerBank {
        private ExecutorService pool = Executors.newFixedThreadPool(45);

        private static int port = 9090;
        ServerSocket server = null;
        
        public ServerBank(){
            try {
                server = new ServerSocket(port);
                while(true){
                    Socket client = server.accept();
                    System.out.println("serverSocket server.accept(); ");
                    ServerBankThread serverThread = new ServerBankThread(client);
                    serverThread.start();
                    pool.execute(serverThread);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

  • 相关阅读:
    return false 和 return true
    前端异常采集
    Performance — 前端性能监控利器
    正则笔记-忘记就来看
    JS中的正则应用
    iconfont的使用
    canvas笔记1
    树莓派3B安装DeBian 64位系统及其安装私有云网盘----可道云
    台灯改造【智能台灯】
    单片机C语言中标志位的经典应用
  • 原文地址:https://www.cnblogs.com/Jiphen/p/2564165.html
Copyright © 2011-2022 走看看