百度360必应搜狗淘宝本站头条
nodejsbufferorg.jsoupsetnocountoncv2.bitwise_nottime.strptime
当前位置：网站首页 > 编程字典 > 正文

Java学习:基础(网络编程二)（java中网络编程）

toyiye 2024-07-11 00:30 9 浏览 0 评论

TCP通信

  • tcp消息一发一收
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 客服端
 */
public class ClinetDemo1 {
    public static void main(String[] args) {

        try {
            System.out.println("客户端启动...");
            // 创建socket 通信管道连接
            String ip = "127.0.0.1";// 服务器端p
            int port = 9999;// 服务端端口
            Socket socket = new Socket(ip, port);
            // 获取字节输出流
            OutputStream os = socket.getOutputStream();
            // 转换成打印流
            PrintStream ps = new PrintStream(os);
            // 输出数据
            ps.println("我是客户端");
            // 刷新数据
            ps.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 服务端
 */
class ServerDemo1 {
    public static void main(String[] args) {
        try {
            System.out.println("服务端启动...");
            // 注册端口
            int port = 9999;
            ServerSocket serverSocket = new ServerSocket(port);
            // 建立通信管道，阻塞等待接收客户端连接
            Socket socket = serverSocket.accept();
            // 读取管道数据字节流
            InputStream is = socket.getInputStream();
            // 字节流转换缓冲字符流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            // 读取消息
            String msg;
            if ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + " 消息：" + msg);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
  • tcp消息多发多收，只能处理一个客户端
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

/**
 * 客服端
 */
public class ClinetDemo2 {
    public static void main(String[] args) {

        try {
            System.out.println("客户端启动...");
            // 创建socket 通信管道连接
            String ip = "127.0.0.1";// 服务器端p
            int port = 9999;// 服务端端口
            Socket socket = new Socket(ip, port);
            // 获取字节输出流
            OutputStream os = socket.getOutputStream();
            // 转换成打印流
            PrintStream ps = new PrintStream(os);
            // 输出数据
            Scanner sc = new Scanner(System.in);
            while (true) {
                System.out.println("请输入：");
                String msg = sc.nextLine();
                ps.println(msg);
                // 刷新数据
                ps.flush();
            }

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 服务端
 */
class ServerDemo2 {
    public static void main(String[] args) {
        try {
            System.out.println("服务端启动...");
            // 注册端口
            int port = 9999;
            ServerSocket serverSocket = new ServerSocket(port);
            // 建立通信管道，阻塞等待接收客户端连接
            Socket socket = serverSocket.accept();
            // 读取管道数据字节流
            InputStream is = socket.getInputStream();
            // 字节流转换缓冲字符流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            // 读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + " 消息：" + msg);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
  • tcp消息多发多收，处理多个客户端
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

/**
 * 服务端
 */
class ServerDemo3 {
    public static void main(String[] args) {
        try {
            System.out.println("服务端启动...");
            // 注册端口
            int port = 9999;
            ServerSocket serverSocket = new ServerSocket(port);
            // 定义主线线程，负责接收socket管道
            while (true) {
                // 建立通信管道，阻塞等待接收客户端连接
                Socket socket = serverSocket.accept();
                // 子线程处理多个客户端
                new ServerReaderThread(socket).start();

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 服务端，线程类
 */
class ServerReaderThread extends Thread{
    private Socket socket;
    public ServerReaderThread(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            // 读取管道数据字节流
            InputStream is = socket.getInputStream();
            // 字节流转换缓冲字符流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            // 读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + " 消息：" + msg);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
  • tcp消息多发多收，线程池处理多个客户端
/**
 * 服务端
 */
class ServerDemo4 {

    // 使用静态变量记住一个线程池对象
    private static ExecutorService pool = new ThreadPoolExecutor(3, 5,6,TimeUnit.SECONDS, new ArrayBlockingQueue<>(2), Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
    public static void main(String[] args) {
        try {
            System.out.println("服务端启动...");
            // 注册端口
            int port = 9999;
            ServerSocket serverSocket = new ServerSocket(port);
            // 定义主线线程，负责接收socket管道
            while (true) {
                // 建立通信管道，阻塞等待接收客户端连接
                Socket socket = serverSocket.accept();
                // 线程池处理多个客户端
                Runnable target = new ServerReaderRunnable(socket);
                pool.execute(target);

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 任务类
 */
class ServerReaderRunnable implements Runnable{
    private Socket socket;
    public ServerReaderRunnable(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            // 读取管道数据字节流
            InputStream is = socket.getInputStream();
            // 字节流转换缓冲字符流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            // 读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + " 消息：" + msg);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

即时通信

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

/**
 * 客服端
 */
public class ClinetDemo5 {
    public static void main(String[] args) {

        try {
            System.out.println("客户端启动...");
            // 创建socket 通信管道连接
            String ip = "127.0.0.1";// 服务器端p
            int port = 9999;// 服务端端口
            Socket socket = new Socket(ip, port);

            // 独立线程接收服务端消息
            new ClinetReaderThread5(socket).start();

            // 获取字节输出流
            OutputStream os = socket.getOutputStream();
            // 转换成打印流
            PrintStream ps = new PrintStream(os);
            // 输出数据
            Scanner sc = new Scanner(System.in);
            while (true) {
                System.out.println("请输入：");
                String msg = sc.nextLine();
                ps.println(msg);
                // 刷新数据
                ps.flush();
            }

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 独立线程接收服务端消息
 */
class ClinetReaderThread5 extends Thread{
    private Socket socket;
    public ClinetReaderThread5(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            // 读取管道数据字节流
            InputStream is = socket.getInputStream();
            // 字节流转换缓冲字符流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            // 读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress()+ "收到消息：" + msg);
            }
        } catch (Exception e) {
            System.out.println("服务器异常");
        }
    }
}


/**
 * 服务端
 */
class ServerDemo5 {
    // 存储所有在线socket 管道
    public static List<Socket> allOnlineSockets = new ArrayList<>();
    public static void main(String[] args) {
        try {
            System.out.println("服务端启动...");
            // 注册端口
            int port = 9999;
            ServerSocket serverSocket = new ServerSocket(port);
            // 定义主线线程，负责接收socket管道
            while (true) {
                // 建立通信管道，阻塞等待接收客户端连接
                Socket socket = serverSocket.accept();
                // 上线添加
                allOnlineSockets.add(socket);
                // 子线程处理多个客户端
                new ServerReaderThread5(socket).start();

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 服务端，线程类
 */
class ServerReaderThread5 extends Thread{
    private Socket socket;
    public ServerReaderThread5(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            // 读取管道数据字节流
            InputStream is = socket.getInputStream();
            // 字节流转换缓冲字符流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            // 读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + " 消息：" + msg);
                // 端口转发
                sendMsgToAll(msg);
            }
        } catch (Exception e) {
            System.out.println(socket.getRemoteSocketAddress() + "下线");
            // 下线移除
            ServerDemo5.allOnlineSockets.remove(socket);

        }
    }

    /**
     * 端口转化数据
     * @param msg
     * @throws Exception
     */
    private void sendMsgToAll(String msg) throws Exception {
        for (Socket socket : ServerDemo5.allOnlineSockets) {
            PrintStream ps = new PrintStream(socket.getOutputStream());
            ps.println(msg);
            ps.flush();
        }
    }
}

相关推荐

为何越来越多的编程语言使用JSON（为什么编程）

JSON是JavascriptObjectNotation的缩写，意思是Javascript对象表示法，是一种易于人类阅读和对编程友好的文本数据传递方法，是JavaScript语言规范定义的一个子...

何时在数据库中使用 JSON（数据库用json格式存储）

在本文中，您将了解何时应考虑将JSON数据类型添加到表中以及何时应避免使用它们。每天?分享?最新?软件?开发?，Devops，敏捷?，测试?以及?项目?管理?最新?，最热门?的?文章?，每天?花?...

MySQL 从零开始:05 数据类型（mysql数据类型有哪些,并举例）

前面的讲解中已经接触到了表的创建，表的创建是对字段的声明，比如：上述语句声明了字段的名称、类型、所占空间、默认值和是否可以为空等信息。其中的int、varchar、char和decimal都...

JSON对象花样进阶（json格式对象）

一、引言在现代Web开发中，JSON（JavaScriptObjectNotation）已经成为数据交换的标准格式。无论是从前端向后端发送数据，还是从后端接收数据，JSON都是不可或缺的一部分。...

深入理解 JSON 和 Form-data（json和formdata提交区别）

在讨论现代网络开发与API设计的语境下，理解客户端和服务器间如何有效且可靠地交换数据变得尤为关键。这里，特别值得关注的是两种主流数据格式：...

JSON 语法（json 语法 priority）

JSON语法是JavaScript语法的子集。JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔花括号保存对象方括号保存数组JS...

JSON语法详解（json的语法规则）

JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔大括号保存对象中括号保存数组注意：json的key是字符串,且必须是双引号，不能是单引号...

MySQL JSON数据类型操作（mysql的json）

概述mysql自5.7.8版本开始，就支持了json结构的数据存储和查询，这表明了mysql也在不断的学习和增加nosql数据库的有点。但mysql毕竟是关系型数据库，在处理json这种非结构化的数据...

JSON的数据模式（json数据格式示例）

像XML模式一样，JSON数据格式也有Schema，这是一个基于JSON格式的规范。JSON模式也以JSON格式编写。它用于验证JSON数据。JSON模式示例以下代码显示了基本的JSON模式。{"...

前端学习——JSON格式详解（后端json格式）

JSON(JavaScriptObjectNotation)是一种轻量级的数据交换格式。易于人阅读和编写。同时也易于机器解析和生成。它基于JavaScriptProgrammingLa...

什么是 JSON:详解 JSON 及其优势（什么叫json）

现在程序员还有谁不知道JSON吗？无论对于前端还是后端，JSON都是一种常见的数据格式。那么JSON到底是什么呢？JSON的定义...

PostgreSQL JSON 类型:处理结构化数据

PostgreSQL提供JSON类型，以存储结构化数据。JSON是一种开放的数据格式，可用于存储各种类型的值。什么是JSON类型？JSON类型表示JSON(JavaScriptO...

JavaScript:JSON、三种包装类（javascript 包）

JOSN:我们希望可以将一个对象在不同的语言中进行传递，以达到通信的目的，最佳方式就是将一个对象转换为字符串的形式JSON（JavaScriptObjectNotation）-JS的对象表示法...

Python数据分析 只要1分钟 教你玩转JSON 全程干货

Json简介：Json，全名JavaScriptObjectNotation,JSON(JavaScriptObjectNotation(记号、标记))是一种轻量级的数据交换格式。它基于J...

比较一下JSON与XML两种数据格式?（json和xml哪个好）

JSON（JavaScriptObjectNotation）和XML（eXtensibleMarkupLanguage）是在日常开发中比较常用的两种数据格式，它们主要的作用就是用来进行数据的传...

取消回复欢迎 你 发表评论:

请填写验证码
一周热门
最近发表
标签列表