当前位置: 开发笔记 > 编程语言 > 正文

8.9.网络编程_Socket远程调用机制

作者：灰包蛋啦_199 | 来源：互联网 | 2023-09-11 18:48

1.网络编程1.1.网络编程概述：通过通信线路（有线或无线）可以把不同地理位置且相互独立的计算机连同其外部设备连接起来，组成计算机网络。在操作系统、网络管理软件及网络通信协议的管理

1.网络编程

1.1.网络编程概述：

　　通过通信线路（有线或无线）可以把不同地理位置且相互独立的计算机连同其外部设备连接起来，组成计算机网络。在操作系统、网络管理软件及网络

通信协议的管理和协调下，可以实现计算机之间的资源共享和信息的传递

　　网络编程是指用来实现网络互联的不同计算机上运行的程序间可以进行数据交换。对我们来说即如何用编程语言 java 实现计算机网络中不同计算机之间

的通信

1.2.网络通信三要素

　　1.2.1：IP 地址： 网络中计算机的唯一标识；32bit（4 字节），一般用“点分十进制”表示，如 192.168.1.158；

　　　　IP 地址=网络地址＋主机地址可分类：

　　　　 8.9.网络编程_Socket 远程调用机制

　　Java 编程中可使用 InetAddress 类来操纵 IP 地址

public static void main(String[] args) throws UnknownHostException {
 　　InetAddress localHost = InetAddress.getLocalHost();
 　　System.out.println(localHost.getHostAddress());
 　　System.out.println(localHost.getHostName());
}

　　1.2.2：端口号：用于标识进程的逻辑地址，不同进程的标识；有效端口：0-65535，其中 0-1024 系统使用或保留端口

　　1.2.3：传输协议：通讯的规则常见协议： UDP（用户数据报协议）、TCP（传输控制协议）

　　　　 8.9.网络编程_Socket 远程调用机制

1.3. 网络模型

　　计算机网络之间以何种规则进行通信，就是网络模型所研究的问题

　　网络模型一般是指 OSI 七层参考模型和 TCP/IP 五层参考模型

　　 8.9.网络编程_Socket 远程调用机制

　　每一层实现各自的功能和协议，并且都为上一层提供业务功能。为了提供这种业务功能，下一层将上一层中的数据并入到本层的数据域中，

然后通过加入报头或报尾来实现该层业务功能，该过程叫做数据封装。用户的数据要经过一次次包装，最后转化成可以在网络上传输的信号，

发送到网络上。当到达目标计算机后，再执行相反的数据拆包过程

　　 8.9.网络编程_Socket 远程调用机制

　　1.物理层：主要定义物理设备标准，如网线的接口类型、光纤的接口类型、各种传输介质的传输速率等。主要作用是将数据最终编码为用 0、1

标识的比特流，通过物理介质传输。这一层的数据叫做比特

　　2.数据链路层：主要将接收到的数据进行 MAC 地址（网卡地址）的封装与解封装。常把这一层的数据叫做帧。这一层常工作的设备是交换机

　　3.网络层：主要将接收到的数据进行 IP 地址的封装与解封装。常把这一层的数据叫做数据包。这一层设备是路由器

　　4.传输层：定义了一些数据传输的协议和端口号。主要将接收的数据进行分段和传输，到达目的地址后在进行重组。常把这一层的数据叫做段

　　5.会话层：通过传输层建立数据传输的通路。主要在系统之间发起会话或者接收会话请求

　　6.表示层：主要进行对接收数据的解释、加密与解密、压缩与解压缩。确保一个系统的应用层发送的数据能被另一个系统的应用层识别

　　7.应用层：主要是为一些终端应用程序提供服务。直接面对着用户的

1.4.Socket 远程调用机制

4.1.Socket 概述

　　Socket,又称为套接字，用于描述 IP 地址和端口。应用程序通常通过 socket向网络发出请求或者应答网络请求。

　　Socket 就是为网络编程提供的一种机制：通信两端都有 socket；网络通信其实就是 socket 之间的通信；数据在两个 socket 之间通过 IO 传输。

　　网络编程也称作为 Socket 编程，套接字编程。Socket通信是 Client/Server 模型

4.2.基于 UDP 协议的 Socket 通信：核心类：DatagramSocket

　　客户端：

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
/**
 * Created by Administrator on 2018/6/7.
 */
public class SocketUDP {
    public static void main(String[] args) throws Exception {
        // 创建发送端 Socket 服务对象
        DatagramSocket dSocket = null;
        try {
            dSocket = new DatagramSocket();
            // 创建数据，打包数据
            String message = "hello ,are u UDP ?";
            byte[] bys = message.getBytes();
            int length = bys.length;
            InetAddress address = InetAddress.getByName("localhost");
            int port = 12621;
            DatagramPacket dPacket = new DatagramPacket(bys, length, address, port);
            // 发送数据
            dSocket.send(dPacket);
            // 资源释放
            dSocket.close();
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }
}

　　接收端：

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
 * Created by Administrator on 2018/6/7.
 */
public class SocketUDPServer {
    public static void main(String[] args) throws Exception {
        //创建接收端 Socket 服务对象
        DatagramSocket dSocket = new DatagramSocket(12621);
        //创建数据包（接收容器）
        byte[] bys = new byte[1024];
        DatagramPacket dPacket = new DatagramPacket(bys, bys.length);
        //调用接收方法
        dSocket.receive(dPacket);
        //数据包解析
        InetAddress address = dPacket.getAddress();
        String hostAddress = address.getHostAddress();
        byte[] data = dPacket.getData();
        String message = new String(data);
        System.out.println(hostAddress+"*********:"+message);
        //资源释放
        dSocket.close();
    }
}

4.3. 基于 TCP 协议的 Socket 通信

　　客户端：核心 API：Socket　

import java.io.OutputStream;
import java.net.Socket;

/**
 * Created by Administrator on 2018/6/7.
 */
public class SocketTCPClient {
    public static void main(String[] args) throws  Exception{
        //创建客户端的 socket 服务，指定目的主机和端口
        Socket s = new Socket("127.0.0.1", 13131);
        //通过 socket 获取输出流，写数据
        OutputStream outputStream = s.getOutputStream();
        outputStream.write("hello ,this is tcp?".getBytes());
        //释放资源
        s.close();
    }
}

　　服务端：核心 API：ServerSocket

import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * Created by Administrator on 2018/6/7.
 */
public class SocketTCPServer {
    public static void main(String[] args) throws Exception {
        //建立服务端 socket 服务，并且监听一个端口
        ServerSocket ss = new ServerSocket(13131);
        //监听连接
        Socket s = ss.accept();
        //获取输入流，读取数据
        InputStream inputStream = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = inputStream.read(bys);
        System.out.println(new String(bys, 0, len));
        //关闭客户端
        s.close();
        //关闭服务端，一般服务端不关闭
        ss.close();
    }
}

服务端代码2：

import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class ServiceServer {

    public static void main(String[] args) throws Exception {

        // 创建一个serversocket，绑定到本机的8899端口上
        ServerSocket server = new ServerSocket();
        server.bind(new InetSocketAddress("localhost", 8899));

        // 接受客户端的连接请求;accept是一个阻塞方法，会一直等待，直到有客户端请求连接才返回
        while (true) {
            Socket socket = server.accept();
　　　　　　　//业务实现
            new Thread(new ServiceServerTask(socket)).start();
        }
    }
}

业务类：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ServiceServerTask implements Runnable{
    Socket socket ;
    InputStream in=null;
    OutputStream out = null;
    
    public ServiceServerTask(Socket socket) {
        this.socket = socket;
    }

    //业务逻辑：跟客户端进行数据交互
    @Override
    public void run() {
         try {
            //从socket连接中获取到与client之间的网络通信输入输出流 
            in = socket.getInputStream();
            out = socket.getOutputStream();            
            
            BufferedReader br = new BufferedReader(new InputStreamReader(in));
            //从网络通信输入流中读取客户端发送过来的数据
            //注意：socketinputstream的读数据的方法都是阻塞的 
            String param = br.readLine();
            
            /**
             * 可以根据客户端发过来的调用类名、调用方法名、调用该参数来灵活调用
             * 《反射》
             */
            
            GetDataServiceImpl getDataServiceImpl = new GetDataServiceImpl();
            String result = getDataServiceImpl.getData(param);
            
            
            //将调用结果写到sokect的输出流中，以发送给客户端
            PrintWriter pw = new PrintWriter(out);
            pw.println(result);
            pw.flush();
            
        } catch (IOException e) {
             
            e.printStackTrace();
        }finally{
            try {
                in.close();
                out.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }    
        }        
    }
}

接口类：

public class GetDataServiceImpl {
    
    public String getData(String param){    
        return "ok-"+param;
    }
}

客户端：

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ServiceClient {

    public static void main(String[] args) throws Exception {
        
        /*ServiceIterface service = ProxyUtils.getProxy(ServiceIterface.class,"methodA",hostname,port);
        Result = service.methodA(parameters);*/
        
        // 向服务器发出请求建立连接
        Socket socket = new Socket("localhost", 8899);
        // 从socket中获取输入输出流
        InputStream inputStream = socket.getInputStream();
        OutputStream outputStream = socket.getOutputStream();

        PrintWriter pw = new PrintWriter(outputStream);
        pw.println("hello");
        pw.flush();

        BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));
        String result = br.readLine();
        System.out.println(result);
        
        inputStream.close();
        outputStream.close();
        socket.close();    
    }
}

推荐阅读

main
c/c++常用代码doc,ppt,xls文件格式转PDF格式[转]

[转]doc,ppt,xls文件格式转PDF格式http:blog.csdn.netlee353086articledetails7920355确实好用。需要注意的是#import ... [详细]

蜡笔小新 2024-11-12 16:19:40
main
Spring – Bean Life Cycle

Spring – Bean Life Cycle ... [详细]

蜡笔小新 2024-11-13 13:24:40
char
c语言拓展数学函数库,c语言数学库

C语言中全部可用的数学函数有哪些？2．longlabs(longn);求长整型数的绝对值。3．doublefabs(doublex);求实数的绝对值。4．doublefloor(d ... [详细]

蜡笔小新 2024-11-13 14:46:34
main
Java DAO模式详解与代码示例

DAO（Data Access Object）模式是一种用于抽象和封装所有对数据库或其他持久化机制访问的方法，它通过提供一个统一的接口来隐藏底层数据访问的复杂性。 ... [详细]

蜡笔小新 2024-11-13 12:25:33
get
Java 编程错误：对象无法转换为 long 类型

本文介绍了在 Java 编程中遇到的一个常见错误：对象无法转换为 long 类型，并提供了详细的解决方案。 ... [详细]

蜡笔小新 2024-11-13 10:57:24
main
面试中如何回答“零拷贝”技术问题？

零拷贝技术是提高I/O性能的重要手段，常用于Java NIO、Netty、Kafka等框架中。本文将详细解析零拷贝技术的原理及其应用。 ... [详细]

蜡笔小新 2024-11-13 02:03:52
main
如何在Java中使用DButils类

这期内容当中小编将会给大家带来有关如何在Java中使用DButils类，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。D ... [详细]

蜡笔小新 2024-11-12 13:46:11
match
检查在所有可能的“？”替换中，给定的二进制字符串中是否出现子字符串“10”带 1 或 0

检查在所有可能的“？”替换中，给定的二进制字符串中是否出现子字符串“10”带 1 或 0 ... [详细]

蜡笔小新 2024-11-12 11:35:01
get
SpringMVC 入门指南：快速上手 Java Web 开发

本文将带你快速了解 SpringMVC 框架的基本使用方法，通过实现一个简单的 Controller 并在浏览器中访问，展示 SpringMVC 的强大与简便。 ... [详细]

蜡笔小新 2024-11-13 14:22:01
main
Flutter 2.* 路由管理详解

本文详细介绍了 Flutter 2.* 中的路由管理机制，包括路由的基本概念、MaterialPageRoute 的使用、Navigator 的操作方法、路由传值、命名路由及其注册、路由钩子等。 ... [详细]

蜡笔小新 2024-11-13 13:45:49
main
Java 并发编程：深入解析 AtomicInteger 和 CAS 无锁算法

在多线程并发环境中，普通变量的操作往往是线程不安全的。本文通过一个简单的例子，展示了如何使用 AtomicInteger 类及其核心的 CAS 无锁算法来保证线程安全。 ... [详细]

蜡笔小新 2024-11-12 16:40:04
eval
Python 使用 DOM 和 SAX 解析 XML 的应用实例

本文介绍如何使用 Python 的 DOM 和 SAX 方法解析 XML 文件，并通过示例展示了如何动态创建数据库表和处理大量数据的实时插入。 ... [详细]

蜡笔小新 2024-11-12 16:10:39
main
Spring Boot 入门指南：Hello World 示例

本教程详细介绍了如何使用 Spring Boot 创建一个简单的 Hello World 应用程序。适合初学者快速上手。 ... [详细]

蜡笔小新 2024-11-12 15:18:38
join
Spring详解（六）AOP

原文网址：https:www.cnblogs.comysoceanp7476379.html目录1、AOP什么？2、需求3、解决办法1:使用静态代理4 ... [详细]

蜡笔小新 2024-11-12 14:40:40
join
小王详解：内部网络中最易理解的NAT原理剖析，挑战你的认知极限

小王详解：内部网络中最易理解的NAT原理剖析，挑战你的认知极限 ... [详细]

蜡笔小新 2024-11-07 15:11:42