zoukankan      html  css  js  c++  java
  • 流式套接字:基于TCP协议的Socket网络编程(案例2)

    案例:在案例1的基础上实现一个服务器对应多个客户端(多线程),且获得每个客户端的IP。

    线程代码:

    package com.yh.mySocket;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.net.InetAddress;
    import java.net.Socket;
    
    public class LoginThread extends Thread {
        Socket socket = null;
        public LoginThread() {}
        public LoginThread(Socket socket) {
            this.socket = socket;
        }
    
        @Override
        public void run() {
            // TODO Auto-generated method stub
            try {
                // 获得输入流,获得相应的用户请求
                InputStream is = socket.getInputStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(is));
                String info;
                while((info = br.readLine())!=null) {
                    System.out.println(info);
                }
                // 获得客户端IP
                InetAddress ia = socket.getInetAddress();
                String ip = ia.getHostAddress();
                System.out.println("客户端IP地址为:"+ip);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

    客户端代码(多个客户端代码类似):

    package com.yh.mySocket;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    public class LoginClient1 {
        public static void main(String[] args) {
            Socket socket = null;
            OutputStream os = null;
            try {
                // 创建一个客户端Socket,参数为客户端IP和指定端口号,此处客户端和服务器在同一台电脑,所以IP地址相同
                socket = new Socket("localhost",5000);
                // 通过输出流,给服务器发送请求
                os = socket.getOutputStream();
                String info = "用户名:YeHuan1; 密码:12345";
                byte[] infos = info.getBytes();
                os.write(infos);
            } catch (UnknownHostException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally {
                try {
                    os.close();
                    socket.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

    服务器代码:

    package com.yh.mySocket;
    
    import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class LoginServer {
        public static void main(String[] args) {
            ServerSocket serversocket = null;
            Socket socket = null;
            
            try {
                // 创建一个服务器Socket
                serversocket = new ServerSocket(5000);
                while(true) {
                    // 使用accept()等待用户的通信
                    socket = serversocket.accept();
                    LoginThread lt = new LoginThread(socket);
                    lt.start();
                }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally {
                try {
                    // 释放资源
                    socket.close();
                    serversocket.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
  • 相关阅读:
    php安全模式笔记
    ./configure,make,make install的作用(转)
    composer自动载入类库的方式
    Specified key was too long; max key length is 1000 bytes
    海量数据中找出前k大数(topk问题)
    斐波那契数列n项的值。(递归和非递归算法Golang实现)
    基于Docker和Golang搭建Web服务器
    Nginx简单介绍以及linux下使用Nginx进行负载均衡的搭建
    php实现商城秒杀
    一致性hash (PHP)
  • 原文地址:https://www.cnblogs.com/YeHuan/p/10792905.html
Copyright © 2011-2022 走看看