AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Java网络编程相关内容【下】

2022-04-26 72
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 网络编程 概述 计算机网络： 计算机网络是指将地理位置不同的具有独立功能的多台计算机及其外部设备，通过通信线路连接起来，在网络操作系统，网络管理软件及网络通信协议的管理和协调下，实现资源共享和信息传递的计算机系统。 网络编程的目的： 无线电台...传播交流信息，数据交换。通信 想要达到这个效果需要什

网络编程


TCP

客户端


  1. 连接服务器 Socket


  1. 发送消息


import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
//客户端
public class TcpClientDemo01 {
    public static void main(String[] args) {
        Socket socket = null;
        OutputStream os = null;
        //1.要知道服务器的地址
        try {
            InetAddress serverIP = InetAddress.getByName("127.0.0.1");
            //2.端口号
            int port = 9999;
            //3.创建一个socket连接
            socket = new Socket(serverIP,port);
            //4.发送消息    IO流
            os = socket.getOutputStream();
            os.write("你好，欢迎学习狂神说Java".getBytes());
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            if (os!=null){
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}


服务器


  1. 建立服务的端口 ServerSocket


  1. 等待用户的连接 accept


  1. 接受用户的消息


import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
//服务端
public class TcpServerDemo01 {
    public static void main(String[] args) {
        ServerSocket serverSocket=null;
        Socket socket=null;
        InputStream is=null;
        ByteArrayOutputStream baos=null;
        try {
            //1.我得有一个地址
            serverSocket = new ServerSocket(9999);
            while (true){       //连续接收客户端消息
                //2.等待客户端连接过来
                socket = serverSocket.accept();
                //3.读取客户端的消息
                is = socket.getInputStream();
            /*
            byte[] buffer = new byte[1024];
            int len;
            while ((len = is.read(buffer))!=-1){
                String msg = new String(buffer, 0, len);
                System.out.println(msg);
            }
             */
                //管道流
                baos = new ByteArrayOutputStream();
                byte[] buffer = new byte[1024];
                int len;
                while ((len = is.read(buffer))!=-1){
                    baos.write(buffer,0,len);
                }
                System.out.println(baos.toString());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            //关闭资源
            if (baos!=null){
                try {
                    baos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (is!=null){
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (serverSocket!=null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}


TCP文件上传

服务器端


import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class TcpServerDemo02 {
    public static void main(String[] args) throws Exception {
        //1.创建服务
        ServerSocket serverSocket = new ServerSocket(9000);
        //2.监听客户端的连接
        Socket socket = serverSocket.accept();//阻塞式监听，会一直等待客户端连接
        //3.获取输入流
        InputStream is = socket.getInputStream();
        //4.文件输出
        FileOutputStream fos = new FileOutputStream("receive.jpg");
        byte[] buffer = new byte[1024];
        int len;
        while ((len = is.read(buffer))!=-1){
            fos.write(buffer,0,len);
        }
        //通知客户端我接收完毕了
        OutputStream os = socket.getOutputStream();
        os.write("我接收完毕了，你可以断开了".getBytes());
        //关闭资源
        fos.close();
        is.close();
        socket.close();
        serverSocket.close();
    }
}


客户端


import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
public class TcpClientDemo02 {
    public static void main(String[] args) throws Exception {
        //1.创建一个Socket连接
        Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9000);
        //2.创建一个输出流
        OutputStream os = socket.getOutputStream();
        //3.读取文件
        FileInputStream fis = new FileInputStream(new File("D:\\environment\\java_project\\javase\\蜗牛.jpg"));
        //4.写出文件
        byte[] buffer = new byte[1024];
        int len;
        while ((len = fis.read(buffer))!=-1){
            os.write(buffer,0,len);
        }
        //通知服务器，我已经结束了
        socket.shutdownOutput();//我已经传输完了！
        //确定服务器接收完毕，才能够断开连接
        InputStream inputStream = socket.getInputStream();
        //String byte[]
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        byte[] buffer2 = new byte[1024];
        int len2;
        while ((len2 = inputStream.read(buffer2))!=-1){
            baos.write(buffer2,0,len2);
        }
        System.out.println(baos.toString());
        //5.关闭资源
        baos.close();
        inputStream.close();
        fis.close();
        os.close();
        socket.close();
    }
}


Tomcat

服务器


  • 自定义 S


  • Tomcat 服务器 S：Java后台开发！

客户端


  • 自定义 C


  • 浏览器 B


UDP

发短信：不用连接，需要知道对方的地址


发送端


import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
//不需要连接服务器
public class UdpClientDemo01 {
    public static void main(String[] args) throws Exception {
        //1.建立一个Socket
        DatagramSocket socket = new DatagramSocket();
        //2.建个包
        String msg = "你好啊，服务器！";
        //发送给谁
        InetAddress localhost = InetAddress.getByName("localhost");
        int port = 9090;
        //数据，数据的长度起始，要发送给谁
        DatagramPacket packet = new DatagramPacket(msg.getBytes(), 0, msg.getBytes().length,localhost,port);
        //3.发送包
        socket.send(packet);
        //4.关闭流
        socket.close();
    }
}


接收端


import java.net.DatagramPacket;
import java.net.DatagramSocket;
//还是要等待客户端的连接！
public class UdpServerDemo01 {
    public static void main(String[] args) throws Exception {
        //开放端口
        DatagramSocket socket = new DatagramSocket(9090);
        //接收数据包
        byte[] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);//
        socket.receive(packet);//阻塞接收
        System.out.println(packet.getAddress().getHostAddress());
        System.out.println(new String(packet.getData(),0, packet.getLength()));
        //关闭连接
        socket.close();
    }
}


发送消息


import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
public class UdpSenderDemo01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(8888);
        //准备数据：控制台读取System.in
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        while (true){
            String data = reader.readLine();
            byte[] datas = data.getBytes();
            DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress("localhost", 6666));
            socket.send(packet);
            if (data.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}
======================================================================================
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UdpReceiveDemo01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(6666);
        while (true){
            //准备接受包裹
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container,0,container.length);
            socket.receive(packet);//阻塞式接收包裹
            //断开连接 bye
            byte[] data = packet.getData();
            String receiveData = new String(data, 0, data.length);
            System.out.println(receiveData);
            if (receiveData.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}


在线咨询（两个人都可以是发送方或接收方，实现在线交流）


import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
public class TalkSend implements Runnable{
    DatagramSocket socket = null;
    BufferedReader reader = null;
    private int fromPort;
    private String toIP;
    private int toPort;
    public TalkSend(int fromPort, String toIP, int toPort) {
        this.fromPort = fromPort;
        this.toIP = toIP;
        this.toPort = toPort;
        try {
            socket = new DatagramSocket(fromPort);
            reader = new BufferedReader(new InputStreamReader(System.in));
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    @Override
    public void run() {
        while (true){
            try {
                String data = reader.readLine();
                byte[] datas = data.getBytes();
                DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress(this.toIP,this.toPort));
                socket.send(packet);
                if (data.equals("bye")){
                    break;
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        socket.close();
    }
}
=======================================================================================
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class TalkReceive implements Runnable{
    DatagramSocket socket = null;
    private int port;
    private String msgFrom;
    public TalkReceive(int port,String msgFrom) {
        this.port = port;
        this.msgFrom = msgFrom;
        try {
            socket = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }
    @Override
    public void run() {
        while (true){
            try {
                //准备接受包裹
                byte[] container = new byte[1024];
                DatagramPacket packet = new DatagramPacket(container,0,container.length);
                socket.receive(packet);//阻塞式接收包裹
                //断开连接 bye
                byte[] data = packet.getData();
                String receiveData = new String(data, 0, data.length);
                System.out.println(msgFrom+"："+receiveData);
                if (receiveData.equals("bye")){
                    break;
                }
            }catch (IOException e){
                e.printStackTrace();
            }
        }
        socket.close();
    }
}
=====================================================================================
public class TalkStudent {
    public static void main(String[] args) {
        //开启两个线程
        new Thread(new TalkSend(7777,"localhost",9999)).start();
        new Thread(new TalkReceive(8888,"老师")).start();
    }
}
=======================================================================================
public class TalkTeacher {
    public static void main(String[] args) {
        new Thread(new TalkSend(5555,"localhost",8888)).start();
        new Thread(new TalkReceive(9999,"学生")).start();
    }
}


URL下载网络资源

https://www.baidu.com/

统一资源定位符：定位资源的，定位互联网上的某一个资源

DNS 域名解析 www.baidu.com xxx.x..x..x


协议：//ip地址：端口/项目名/资源


import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
public class UrlDown {
    public static void main(String[] args) throws IOException {
        //1.下载地址
        URL url = new URL("https://p2.music.126.net/WqnSe7WvZOB0E_4qBsNmqw==/109951166086703110.jpg?param=50y50");
        //2.连接到这个资源 HTTP
        HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
        InputStream inputStream = urlConnection.getInputStream();
        FileOutputStream fos = new FileOutputStream("109951166086703110.jpg");
        byte[] buffer = new byte[1024];
        int len;
        while ((len= inputStream.read(buffer))!=-1){
            fos.write(buffer,0,len);//写出这个数据
        }
        fos.close();
        inputStream.close();
        urlConnection.disconnect();
    }
}
文章标签：
Java
应用服务中间件
定位技术
网络协议
域名解析
关键词：
Java网络编程
Java网络
网络编程java
Java内容
Java网络编程相关内容
游客k2gw4fr7y7zie
目录
相关文章
东方睿赢
|
23天前
|
Java 程序员
JAVA程序员的进阶之路：掌握URL与URLConnection，轻松玩转网络资源！
在Java编程中，网络资源的获取与处理至关重要。本文介绍了如何使用URL与URLConnection高效、准确地获取网络资源。首先，通过`java.net.URL`类定位网络资源；其次，利用`URLConnection`类实现资源的读取与写入。文章还提供了最佳实践，包括异常处理、连接池、超时设置和请求头与响应头的合理配置，帮助Java程序员提升技能，应对复杂网络编程场景。
东方睿赢
49 9
东方睿赢
|
23天前
|
人工智能 Java 物联网
JAVA网络编程的未来：URL与URLConnection的无限可能，你准备好了吗？
随着技术的发展和互联网的普及，JAVA网络编程迎来新的机遇。本文通过案例分析，探讨URL与URLConnection在智能API调用和实时数据流处理中的关键作用，展望其未来趋势和潜力。
东方睿赢
42 7
众所周知
|
3月前
|
Java
【思维导图】JAVA网络编程思维升级：URL与URLConnection的逻辑梳理，助你一臂之力！
【思维导图】JAVA网络编程思维升级：URL与URLConnection的逻辑梳理，助你一臂之力！
众所周知
56 1
众所周知
|
3月前
|
XML JSON 搜索推荐
【高手过招】JAVA网络编程对决：URL与URLConnection的高级玩法，你敢挑战吗？
【高手过招】JAVA网络编程对决：URL与URLConnection的高级玩法，你敢挑战吗？
众所周知
70 0
龙大吉
|
23天前
|
Java 开发者
JAVA高手必备：URL与URLConnection，解锁网络资源的终极秘籍！
在Java网络编程中，URL和URLConnection是两大关键技术，能够帮助开发者轻松处理网络资源。本文通过两个案例，深入解析了如何使用URL和URLConnection从网站抓取数据和发送POST请求上传数据，助力你成为真正的JAVA高手。
龙大吉
43 11
喵帕斯先生
|
23天前
|
安全 Java API
深入探索Java网络编程中的HttpURLConnection：从基础到进阶
本文介绍了Java网络编程中HttpURLConnection的高级特性，包括灵活使用不同HTTP方法、处理重定向、管理Cookie、优化安全性以及处理大文件上传和下载。通过解答五个常见问题，帮助开发者提升网络编程的效率和安全性。
喵帕斯先生
42 9
东方睿赢
|
23天前
|
JSON 安全 算法
JAVA网络编程中的URL与URLConnection：那些你不知道的秘密！
在Java网络编程中，URL与URLConnection是连接网络资源的两大基石。本文通过问题解答形式，揭示了它们的深层秘密，包括特殊字符处理、请求头设置、响应体读取、支持的HTTP方法及性能优化技巧，帮助你掌握高效、安全的网络编程技能。
东方睿赢
46 9
龙大吉
|
23天前
|
JSON Java API
JAVA网络编程新纪元：URL与URLConnection的神级运用，你真的会了吗？
本文深入探讨了Java网络编程中URL和URLConnection的高级应用，通过示例代码展示了如何解析URL、发送GET请求并读取响应内容。文章挑战了传统认知，帮助读者更好地理解和运用这两个基础组件，提升网络编程能力。
龙大吉
41 5
进步`于辰
|
27天前
|
Java
[Java]Socket套接字（网络编程入门）
本文介绍了基于Java Socket实现的一对一和多对多聊天模式。一对一模式通过Server和Client类实现简单的消息收发；多对多模式则通过Server类维护客户端集合，并使用多线程实现实时消息广播。文章旨在帮助读者理解Socket的基本原理和应用。
进步`于辰
22 1
java的细水长流
|
1月前
|
安全 网络协议 Java
Java 网络编程详解
《Java网络编程详解》深入浅出地讲解了使用Java进行网络编程的技术和方法。从基础的网络协议介绍到核心的Socket编程，以及高级的NIO与多线程应用，帮助读者全面掌握Java网络编程技能，是Java开发者不可或缺的学习指南。
java的细水长流
91 8

热门文章

最新文章

  • 1
    Python网络编程1--笔记
  • 2
    Java网络编程：实现HTTP模拟器
  • 3
    Java网络编程从入门到精通（33）：非阻塞I/O的缓冲区（Buffer）
  • 4
    Windows Phone 7 网络编程之RSS阅读器
  • 5
    Java网络编程总结 --URLConnection
  • 6
    Java网络编程从入门到精通（29）：服务端Socket的选项
  • 7
    Linux网络编程之原始套接字-ping协议实现
  • 8
    GO语言练习：网络编程 TCP 示例
  • 9
    linux网络编程----->线程同步-->信号量
  • 10
    Python网络编程 - 一个简单的客户端Get请求程序
  • 1
    java接口防爬虫
    132
  • 2
    day14：Java零基础-条件运算符
    43
  • 3
    Java并发编程中的锁机制与性能优化
    53
  • 4
    深入理解Java虚拟机：垃圾收集机制的演变与最佳实践
    53
  • 5
    《手把手教你》系列基础篇（九十五）-java+ selenium自动化测试-框架之设计篇-java实现自定义日志输出（详解教程）
    297
  • 6
    Java并发编程之线程池深度解析
    65
  • 7
    Java中的并发编程：从基础到高级
    68
  • 8
    Java并发编程中的线程安全性与性能优化
    57
  • 9
    《手把手教你》系列基础篇（九十四）-java+ selenium自动化测试-框架设计基础-POM设计模式实现-下篇（详解教程）
    50
  • 10
    Spring Boot框架在java领域的优势
    78

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • Python网络通信程序典型应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 容器的自定义网络
  • 容器的共享网络模型
    • 下一篇
    无影云桌面