后端

系统学习javaweb-05-网络编程

csxiaoyao · 1月23日 · 2017年本文共7661个字 · 预计阅读26分钟390次已读

系统学习javaweb-05-网络编程

Write By CS逍遥剑仙
我的主页: csxiaoyao.com
GitHub: github.com/csxiaoyaojianxian
Email: sunjianfeng@csxiaoyao.com
QQ: 1724338257

1 InetAddress

InetAddress(IP类)

常用方法
----getLocalHost() 获取本机的IP地址对象
----getByName("IP或者主机名") 根据IP地址的字符串或主机名生成IP地址对象（用于获取别人的IP地址对象）
--------getHostAddress() 返回IP地址的字符串
--------getHostName() 返回计算机的主机名

public class test {
    public static void main(String[] args) throws UnknownHostException {
        //获取本机的IP地址对象
        InetAddress address = InetAddress.getLocalHost();
        System.out.println("IP地址："+address.getHostAddress());
        System.out.println("主机名："+address.getHostName());     
        //根据IP地址的字符串或主机名生成IP地址对象
        InetAddress address2 = InetAddress.getByName("SUNSHINE");
        System.out.println("IP地址："+address2.getHostAddress());
        System.out.println("主机名："+address2.getHostName());
        InetAddress[]  arr = InetAddress.getAllByName("www.baidu.com");//域名   
        System.out.println(Arrays.toString(arr));//[www.baidu.com/111.13.100.92, www.baidu.com/111.13.100.91]
    }
}

2 Socket

2.1 UDP

发送端使用步骤：

  1. 建立UDP服务
  2. 准备数据，把数据封装到数据包中发送，发送端的数据包要带套接字
  3. 调用udp的服务，发送数据
  4. 关闭资源
public class test {
    public static void main(String[] args) throws IOException {
        //建立udp的服务
        DatagramSocket datagramSocket = new DatagramSocket();
        //准备数据，把数据封装到数据包中
        String data = "一个udp的例子";
        //创建了一个数据包
        DatagramPacket packet = new DatagramPacket(data.getBytes(), data.getBytes().length,InetAddress.getLocalHost() , 9090);
        //调用udp的服务发送数据包
        datagramSocket.send(packet);
        //关闭资源 - 释放占用的端口号
        datagramSocket.close();
    }
}

接收端的使用步骤

  1. 建立udp的服务
  2. 准备空的数据包接收数据
  3. 调用udp的服务接收数据
  4. 关闭资源
public class test {
    public static void main(String[] args) throws IOException {
        //建立udp的服务，并且要监听一个端口
        DatagramSocket  socket = new DatagramSocket(9090);
        //准备空的数据包用于存放数据
        byte[] buf = new byte[1024];
        DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length); // 1024
        //调用udp的服务接收数据
        socket.receive(datagramPacket); //receive是一个阻塞型的方法，没有接收到数据包之前会一直等待。 数据实际存储到byte数组中
        System.out.println("接收端接收到的数据："+ new String(buf,0,datagramPacket.getLength())); // getLength() 获取数据包存储了几个字节
        //关闭资源
        socket.close();
    }   
}

UDP群聊发送端

//群聊发送端
public class test extends Thread {
    @Override
    public void run() {
        try {
            //建立udp的服务
            DatagramSocket socket = new DatagramSocket();
            //准备数据，把数据封装到数据包中发送
            BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));
            String line = null;
            DatagramPacket packet  = null;
            while((line = keyReader.readLine())!=null){
                //把数据封装到数据包中，然后发送
                packet = new DatagramPacket(line.getBytes(), line.getBytes().length, InetAddress.getByName("192.168.15.255"), 9090);
                //把数据发送出去
                socket.send(packet);
            }
            //关闭资源
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

UDP群聊接收端

//群聊接收端
public class test extends Thread {
    @Override
    public void run() {
        try {
            //建立udp的服务,要监听一个端口
            DatagramSocket socket = new DatagramSocket(9090);
            //准备空的数据包存储数据
            byte[] buf = new byte[1024];
            DatagramPacket packet = new DatagramPacket(buf, buf.length);
            boolean flag = true;
            while(flag){
                socket.receive(packet);
                // packet.getAddress() 获取对方数据包的IP地址对象。
                System.out.println(packet.getAddress().getHostAddress()+"说:"+new String(buf,0,packet.getLength()));
                Thread.sleep(10);
            }
            //关闭资源
            socket.close();
        }catch (IOException e) {
            e.printStackTrace();
        }
    }
}

群聊主类

public class control {
    public static void main(String[] args) {
        ChatReceive chatReceive = new ChatReceive();
        chatReceive.start();
        ChatSender chatSender = new ChatSender();
        chatSender.start();
    }
}

2.2 TCP

客户端

tcp客户端使用步骤：

  1. 建立tcp的客户端服务
  2. 获取到对应的流对象
  3. 写出或读取数据
  4. 关闭资源
//tcp客户端
public class test {
    public static void main(String[] args) throws IOException{
        //建立tcp的服务
        Socket socket  = new Socket(InetAddress.getLocalHost(),9090);
        //获取到Socket的输出流对象
        OutputStream outputStream = socket.getOutputStream();
        //利用输出流对象把数据写出
        outputStream.write("服务端你好".getBytes());
        //获取到输入流对象，读取服务端回送的数据
        InputStream inputStream = socket.getInputStream();
        byte[] buf = new byte[1024];
        int length = inputStream.read(buf);
        System.out.println("客户端接收到的数据："+ new String(buf,0,length));   
        //关闭资源
        socket.close();     
    }
}

服务端

ServerSocket的使用步骤

  1. 建立tcp服务端服务
  2. 接受客户端的连接产生一个Socket
  3. 获取对应的流对象读取或者写出数据
  4. 关闭资源
//服务端
public class test {
    public static void main(String[] args) throws Exception {
        //建立Tcp的服务端,并且监听一个端口
        ServerSocket serverSocket = new ServerSocket(9090);
        //接受客户端的连接
        Socket socket  =  serverSocket.accept(); //accept() 接受客户端的连接，该方法也是一个阻塞型的方法，没有客户端与其连接时，会一直等待下去
        //获取输入流对象，读取客户端发送的内容
        InputStream inputStream = socket.getInputStream();
        byte[] buf = new byte[1024];
        int length = 0;
        length = inputStream.read(buf);
        System.out.println("服务端接收："+ new String(buf,0,length));
        //获取socket输出流对象，想客户端发送数据
        OutputStream outputStream = socket.getOutputStream();
        outputStream.write("客户端你好".getBytes());
        //关闭资源
        serverSocket.close();
    }
}

群聊

注意事项：

  1. 如果使用BuffrerdReader的readline方法一定要加上\r\n才把数据写出
  2. 使用字符流一定要调用flush方法数据才会写出

TCP群聊客户端

//群聊客户端
public class test {
    public static void main(String[] args) throws IOException {
        //建立tcp的客户端服务
        Socket socket = new Socket(InetAddress.getLocalHost(),9090);
        //获取socket的输出流对象。
        OutputStreamWriter socketOut =  new OutputStreamWriter(socket.getOutputStream());
        //获取socket的输入流对象
        BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));   
        //获取键盘的输入流对象，读取数据
        BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));
        String line = null;
        //不断的读取键盘录入的数据，然后把数据写出
        while((line = keyReader.readLine())!=null){
            socketOut.write(line+"\r\n");
            //刷新
            socketOut.flush();      
            //读取服务端回送的数据
            line = socketReader.readLine();
            System.out.println("服务端回送的数据是："+line);
        }
        //关闭资源
        socket.close();
    }
}

TCP群聊服务端

//群聊服务端
public class test {
    public static void main(String[] args) throws IOException {
        //建立tcp的服务端
        ServerSocket serverSocket = new ServerScsxiaoyao.comocket(9090);
        //接受客户端的连接，产生一个SOcket
        Socket socket = serverSocket.accept();
        //获取到Socket的输入流对象
        BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));   
        //获取到Socket输出流对象
        OutputStreamWriter socketOut =  new OutputStreamWriter(socket.getOutputStream());   
        //获取键盘的输入流对象
        BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));
        //读取客户端的数据
        String line = null;
        while((line = socketReader.readLine())!=null){
            System.out.println("服务端接收到的数据："+ line);
            System.out.println("请输入回送给客户端的数据：");
            line = keyReader.readLine();
            socketOut.write(line+"\r\n");
            socketOut.flush();
        }
        //关闭资源
        serverSocket.close();
    }
}

3 模拟Tomcat服务器

//模拟Tomcat服务器
public class TomcatDemo extends Thread {
    Socket socket;
    public TomcatDemo(Socket socket){
        this.socket = socket;
    }
    public void run() {
        try {
            //获取socket的输出流对象
            OutputStream outputStream = socket.getOutputStream();
            //把数据写到浏览器上
            outputStream.write("<html><head><title>sunshine</title></head><body>浏览器你好</body></html>".getBytes());
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) throws IOException {
        //建立tcp的服务端
        ServerSocket serverSocket = new ServerSocket(9090);
        //不断的接受客户端的连接
        while(true){
            Socket socket = serverSocket.accept();
            new TomcatDemo(socket).start();
        }
    }
}

4 文件上传下载

客户端下载

//下载图片的客户端
public class test {
    public static void main(String[] args) throws Exception{
        //建立tcp的服务
        Socket socket = new Socket(InetAddress.getLocalHost(),9090);
        //获取socket的输入流对象
        InputStream inputStream = socket.getInputStream();
        //获取文件的输出流对象
        FileOutputStream fileOutputStream = new FileOutputStream("F:\\sunshine.jpg");
        //边读边写
        byte[] buf = new byte[1024];
        int length = 0 ; 
        while((length = inputStream.read(buf))!=-1){
            fileOutputStream.write(buf,0,length);
        }
        //关闭资源
        fileOutputStream.close();
        socket.close();
    }
}

服务端给多个客户端发送

//服务端给多个客户端发送图片（多线程）
public class ImageServer extends Thread {
    Socket socket ;
    //使用该集合是用于存储ip地址的。
    static HashSet<String> ips = new HashSet<String>();
    public  ImageServer(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //获取socket输出流对象
            OutputStream outputStream = socket.getOutputStream();
            //获取图片的输入流对象
            FileInputStream fileInputStream = new FileInputStream("F:\\sunshine.jpg");
            //读取图片数据，把数据写出
            byte[] buf = new byte[1024];
            int length = 0 ; 
            while((length = fileInputStream.read(buf))!=-1){
                outputStream.write(buf,0,length);
            }
            String ip = socket.getInetAddress().getHostAddress();   // socket.getInetAddress() 获取对方的IP地址
            if(ips.add(ip)){
                System.out.println( ip+" 成功下载，当前下载的人数是："+ ips.size());
            }
            //关闭资源
            fileInputStream.close();
            socket.close();
        }catch (IOException e) {    
        }
    }
    public static void main(String[] args) throws IOException {
        //建立tcp的服务 ,并且要监听一个端口
        ServerSocket serverSocket  = new ServerSocket(9090);
        while(true){
            //接受用户的链接。
            Socket socket = serverSocket.accept();
            new ImageServer(socket).start();
      csxiaoyao.com  }
    }
}

系统学习javaweb-05-网络编程

相关文章

macos下java版本动态切换

9月22日 · 2017年

系统学习javaweb-14-Lucene

2月1日 · 2017年

系统学习javaweb-13-SpringMVC+Hibernate

1月31日 · 2017年

系统学习javaweb-12-SSH整合开发demo

1月30日 · 2017年
0 条回应
CS逍遥剑仙的博客 | Powered by SUNSHINE STUDIO | csxiaoyao.com
Theme niRvana By michaelliunsky