Java网络通讯精讲

简介: Java网络通讯精讲



网络通讯的三要素

ip地址:计算机在网络中的唯一标识

端口:应用程序在计算机中唯一标识

协议:通信协议,常见有UDP和TCP协议

IP地址:

查看本机地址【ipconfig】

端口号:

用于标识计算机上某个特定的网络程序,以整数形式,范围0-65535。也就是1024*64。

其中前0~1024一般已经被系统占用,示例:【127.0.0.1:8080】

协议:

UDP协议

用户数据报协议(User Datagram Protocol)

UDP是无连接通信协议,即在数据传输时,数据的发送端和接收端不建立逻辑连接

UDP协议消耗系统资源小,通信效率高,所以通常都会用于音频、视频和普通数据的传输

TCP协议

传输控制协议 (Transmission Control Protocol)

TCP协议是面向连接的通信协议,即传输数据之前,在发送端和接收端建立逻辑连接,然后再传输数据,它提供了两台计算机之间可靠无差错的数据传输。

Socket

// 参数一:服务端地址 参数二:服务端端口

Socket socket = new Socket("127.0.0.1", 9527);

1、基础示例

服务端:这里我没有写循环

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
//服务端
public class Server {
  public static void main(String[] args) throws IOException {
    System.out.println("========服务端启动============");
    // 1.创建接收管道,注册端口
    ServerSocket serverSocket = new ServerSocket(9527);// 参数一:定义服务端口
    // 2.等待管道连接
    Socket accept = serverSocket.accept();
    // 3.从管道中获取一个字节输入流
    InputStream is = accept.getInputStream();
    // 4.字节流升级生缓冲输入流
    BufferedReader br = new BufferedReader(new InputStreamReader(is));
    // 5.按照行读取消息会更好
    System.out.println(accept.getRemoteSocketAddress() + "客户端说了:" + br.readLine());
  }
}

客户端:

import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
//发送端
public class Client {
  public static void main(String[] args) throws IOException {
    System.out.println("==============客户端启动===============");
    // 1.创建发送通信管道
    Socket socket = new Socket("127.0.0.1", 9527);// 参数一:服务端地址 参数二:服务端端口
    // 2.从scoket管道中获得一个字节输出流,负责发送数据
    OutputStream os = socket.getOutputStream();
    // 3.字节流升级成打印流
    PrintStream ps = new PrintStream(os);
    // 4.发送消息
    ps.println("我是Client客户端发送给服务端的数据");
    ps.flush();// 刷新
  }
}

先启动服务端,然后再启动客户端,

启动客户端

服务端接收到了客户端的信息。

2、循环监听示例

服务器接收多服务器连续信息,Server代码:

package Demo2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
//服务端
public class Server {
  public static void main(String[] args) throws IOException {
    System.out.println("========服务端启动============");
    // 1.创建接收管道,注册端口
    ServerSocket serverSocket = new ServerSocket(9527);// 参数一:定义服务端口
    while (true) {
      // 2.等待管道连接
      Socket accept = serverSocket.accept();
      // 3.从管道中获取一个字节输入流
      InputStream is = accept.getInputStream();
      // 4.字节流升级生缓冲输入流
      BufferedReader br = new BufferedReader(new InputStreamReader(is));
      // 5.按照行读取消息会更好
      System.out.println(accept.getRemoteSocketAddress() + "客户端说了:" + br.readLine());
    }
  }
}

Client1代码

package Demo2;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
//发送端
public class Client1 {
  public static void main(String[] args) throws IOException {
    System.out.println("==============客户端启动===============");
    Scanner sc = new Scanner(System.in);
    // 1.创建发送通信管道
    // 参数一:服务端地址 参数二:服务端端口
    while (true) {
      Socket socket = new Socket("127.0.0.1", 9527);
      // 2.从scoket管道中获得一个字节输出流,负责发送数据
      OutputStream os = socket.getOutputStream();
      // 3.字节流升级成打印流
      PrintStream ps = new PrintStream(os);
      // 4.发送消息
      String strInfo = sc.next();
      ps.println("Client:"+strInfo);
      ps.flush();// 刷新
    }
  }
}

Client2代码:

package Demo2;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
//发送端
public class Client2 {
  public static void main(String[] args) throws IOException {
    System.out.println("==============客户端启动===============");
    Scanner sc = new Scanner(System.in);
    // 1.创建发送通信管道
    // 参数一:服务端地址 参数二:服务端端口
    while (true) {
      Socket socket = new Socket("127.0.0.1", 9527);
      // 2.从scoket管道中获得一个字节输出流,负责发送数据
      OutputStream os = socket.getOutputStream();
      // 3.字节流升级成打印流
      PrintStream ps = new PrintStream(os);
      // 4.发送消息
      String strInfo = sc.next();
      ps.println("Client2:"+strInfo);
      ps.flush();// 刷新
    }
  }
}

这里Client其实可以有很多很多个,都能访问到对应是主服务器。

示例效果:

切换客户端进行输入:

3、双向互动示例

服务端:

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
//服务端
public class Server {
  public static void main(String[] args) throws IOException {
    System.out.println("========服务端启动============");
    // 1.创建接收管道,注册端口
    ServerSocket serverSocket = new ServerSocket(9527);// 参数一:定义服务端口
    BufferedWriter writer = null;
    while (true) {
      // 2.等待管道连接
      Socket accept = serverSocket.accept();
      writer = new BufferedWriter(
                    new OutputStreamWriter(accept.getOutputStream())
            );
      // 3.从管道中获取一个字节输入流
      InputStream is = accept.getInputStream();
      // 4.字节流升级生缓冲输入流
      BufferedReader br = new BufferedReader(new InputStreamReader(is));
      // 5.按照行读取消息会更好
      String readLine = br.readLine();
      System.out.println(accept.getRemoteSocketAddress() + "客户端说了:" + readLine);
      writer.write("服务器已收到: " + accept.getRemoteSocketAddress() +"消息"+ readLine +"\n");
            //防止消息遗留到本地缓冲区,保证马上发送出去
            writer.flush();
    }
  }
}

Client端:

package Demo2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
//发送端
public class Client1 {
  public static void main(String[] args) throws IOException {
    System.out.println("==============客户端启动===============");
    Scanner sc = new Scanner(System.in);
    // 1.创建发送通信管道
    // 参数一:服务端地址 参数二:服务端端口
    while (true) {
      Socket socket = new Socket("127.0.0.1", 9527);
      // 2.从scoket管道中获得一个字节输出流,负责发送数据
      OutputStream os = socket.getOutputStream();
      // 3.字节流升级成打印流
      PrintStream ps = new PrintStream(os);
      // 4.发送消息
      String strInfo = sc.next();
      ps.println("Client:" + strInfo);
      ps.flush();// 刷新
      // 3.从管道中获取一个字节输入流
      InputStream is = socket.getInputStream();
      // 4.字节流升级生缓冲输入流
      BufferedReader br = new BufferedReader(new InputStreamReader(is));
      // 5.按照行读取消息会更好
      String readLine = br.readLine();
      System.out.println(socket.getRemoteSocketAddress() + "服务端说了:" + readLine);
    }
  }
}

服务端示例效果:

切换到客户端:

双向互动效果完毕。

相关文章
|
25天前
|
网络协议 算法 Java
|
3月前
|
Java 数据格式
最新Java基础系列课程--Day15-网络编程(三)
最新Java基础系列课程--Day15-网络编程
|
3月前
|
存储 网络协议 Java
最新Java基础系列课程--Day15-网络编程(二)
最新Java基础系列课程--Day15-网络编程
|
2天前
|
JavaScript Java 测试技术
基于Java的网络类课程思政学习系统的设计与实现(源码+lw+部署文档+讲解等)
基于Java的网络类课程思政学习系统的设计与实现(源码+lw+部署文档+讲解等)
8 0
基于Java的网络类课程思政学习系统的设计与实现(源码+lw+部署文档+讲解等)
|
22天前
|
网络协议 安全 Java
Java网络编程
Java网络编程
C4.
|
1月前
|
Java
Java网络编程
Java网络编程
C4.
15 0
|
1月前
|
网络协议 Java
Java基于TCP的网络编程
Java基于TCP的网络编程
|
1月前
|
数据采集 前端开发 JavaScript
Java网络爬虫实践:解析微信公众号页面的技巧
Java网络爬虫实践:解析微信公众号页面的技巧
|
2月前
|
消息中间件 网络协议 Java
使用Java进行网络编程
使用Java进行网络编程
|
2月前
|
Java
[Java]Socket套接字(网络编程入门)
[Java]Socket套接字(网络编程入门)
35 0