java 中的socket （demo +心跳 +重连）

使用Socket 实现最简单的通讯

客户端

package SocketDemo;

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

/**
 * Created by kumamon on 2021/5/28.
 *
 * TCP 通信demo
 */
public class Socket_Clicent {


    public static void main(String[] args) throws IOException {
        Socket socket =new Socket("127.0.0.1",8888);
        OutputStream outputStream = socket.getOutputStream();
        outputStream.write("你好服务器".getBytes());
        InputStream inputStream = socket.getInputStream();

        byte[] bytes = new byte[1024];
        int len=0;
        while ((len=inputStream.read(bytes))!=-1){
            System.out.println(new String(bytes));
        }
        socket.close();
    }
}

服务端

package SocketDemo;

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

/**
 * Created by kumamon on 2021/5/28.
 *
 *  服务器的流也是 使用 client 传递过来的socket获取的
 *  说白了 socket就是一个管道
 */
public class Socket_Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket=new ServerSocket(8888);
        Socket accept = serverSocket.accept();  //获取和clicent 交互的 socket
        InputStream inputStream = accept.getInputStream();
        OutputStream outputStream = accept.getOutputStream();

        byte[] bytes = new byte[1024];
        StringBuilder sb=new StringBuilder();
        int len=0;
        while ((len=inputStream.read(bytes))!=-1){
            System.out.println(new String(bytes));
            outputStream.write("服务器收到了，谢谢".getBytes());
        }
    }
}

简单的通讯心跳重连

客户端

package Socket_QQ;

import java.io.*;
import java.net.Socket;
import java.util.Scanner;



/**
 * Created by kumamon on 2021/5/28.
 */
public class TCP_Client {
    private static Socket socket;
    public static boolean connection_state = false;

    public static void main(String[] args){
        while (!connection_state) {
            connect();
            try {
                Thread.sleep(3000);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }

    private static void connect(){
        try {
            socket = new Socket("127.0.0.1", 10086);
            connection_state = true;

            new Thread(new Client_listen(socket)).start();
            new Thread(new Client_send(socket)).start();
            new Thread(new Client_heart(socket)).start();
        }catch (Exception e){
            e.printStackTrace();
            connection_state = false;
        }
    }

    public static void reconnect(){
        while (!connection_state){
            System.out.println("正在尝试重新链接.....");
            connect();
            try {
                Thread.sleep(3000);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}

class Client_listen implements Runnable{
    private Socket socket;


    Client_listen(Socket socket){
        this.socket = socket;

    }

    @Override
    public void run() {
        try {
            InputStream ois = socket.getInputStream();

            int len=0;
            byte[] bytes = new byte[1024];
            while ((len=ois.read(bytes))!=-1){
                System.out.println(new String(bytes,0,len));
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

class Client_send implements Runnable{
    private Socket socket;


    Client_send(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            OutputStream oos = socket.getOutputStream();
            Scanner scanner = new Scanner(System.in);
            while (true){
                System.out.print("请输入你要发送的信息：");
                String string = scanner.nextLine();
                oos.write(string.getBytes());
                oos.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
            try {
                socket.close();
                TCP_Client.connection_state = false;
                TCP_Client.reconnect();
            }catch (Exception ee){
                ee.printStackTrace();
            }
        }
    }
}

class Client_heart implements Runnable{
    private Socket socket;

    Client_heart(Socket socket){
        this.socket = socket;

    }

    @Override
    public void run() {
        try {
            OutputStream oos = socket.getOutputStream();
            System.out.println("心跳包线程已启动...");
            while (true){
                Thread.sleep(5000);
                oos.write("心跳包..".getBytes());
                oos.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
            try {
                socket.close();
                TCP_Client.connection_state = false;
                TCP_Client.reconnect();
            }catch (Exception ee){
                ee.printStackTrace();
            }
        }
    }
}

服务端

package Socket_QQ;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

/**
 * Created by kumamon on 2021/5/28.
 */
public class TCP_Server {
    public static ServerSocket serverSocket;
    private static Socket socket;

    public static void main(String[] args) {

        try {
            System.out.println("服务器已经启动....");
             serverSocket = new ServerSocket(10086);
            while (true) {
                //阻塞的。只有当socket 有连接后才会执行后面的程序
                //有可能断开。也有可能多个客户端连接，所以这里使用 死循环，一直接收
                socket = serverSocket.accept();

                new Thread(new Server_getMessage(socket)).start();
                new Thread(new Server_sendMessage(socket)).start();

            }
        } catch (IOException e) {
            try {
                socket.close();
                serverSocket.close();
            } catch (IOException e1) {
                e1.printStackTrace();
            }

            e.printStackTrace();
        }
    }
}

class Server_getMessage implements Runnable {
    private Socket socket;


    public Server_getMessage(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            InputStream is = socket.getInputStream();
            byte[] bytes = new byte[1024];
            int len=0;
            while ((len=is.read(bytes))!=-1) {  //死循环一直读取消息
                String message = new String(bytes,0,len);
                System.out.println();
                System.out.println("收到消息：" + message);
            }

        } catch (IOException e) {
            try {
                socket.close();

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

        }
    }
}

class Server_sendMessage implements Runnable {
    private Socket socket;


    public Server_sendMessage(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            System.out.println("已经有客户端连接------");
            OutputStream os = socket.getOutputStream();
            Scanner scanner = new Scanner(System.in);
            while (true) {   //scanner 默认是阻塞的，所以这个死循环必须得通畅以后才可以继续执行，所以必须输入一次后才可以继续执行
                System.out.print("发送:");
                String message = scanner.next();
                os.write(message.getBytes());
                os.flush();
            }
        } catch (IOException e) {
            try {
                socket.close();
            } catch (IOException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();

        }
    }
}

模拟文件上传

客户端

package Socket_File_UpLoad;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

/**
 * Created by kumamon on 2021/5/31.
 */
public class Socket_Filte_UpLoad_client {
    public static void main(String[] args) throws IOException {
        //创建本地输入流对象  准备读取需要上传的数据
        FileInputStream fis = new FileInputStream("d:\\1.jpg");
        Socket socket = new Socket("127.0.0.1", 10087);      // 创建和服务器交互的socket对象，

        OutputStream outputStream = socket.getOutputStream();         //创建和服务器交互的输出流对象。准备向服务器发送数据


        /**
         * 注意：
         * 因为 我们读文件是以-1结束的
         * 所以当文件结束后，不会进入循环
         * 那么-1这个结束标记不会上传到服务器
         * 所以服务器没有结束标记会一直阻塞（read 的方法，如果没有消息，会一直阻塞的）
         *
         * 客户端会等待服务器回传的“上传成功”
         * 所以也会阻塞
         * 这个时候我们需要结束客户端发送的输出流（模拟结束标记）
         * */
        int len;
        byte[] bytes = new byte[1024];
        while ((len = fis.read(bytes)) != -1) {
            outputStream.write(bytes, 0, len);
        }
        socket.shutdownOutput();  //关闭输出流，那么客户端的输入流结束

        InputStream inputStream = socket.getInputStream();           //获取服务器回传的数据

        if(socket.isConnected()){
            while ((len = inputStream.read(bytes)) != -1) {
                System.out.println(new String(bytes, 0, len));
            }
        }


        fis.close();   //关闭流
        socket.close();

    }

}

服务端

package Socket_File_UpLoad;


import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;

/**
 * Created by kumamon on 2021/5/31.
 */
public class Socket_File_UpLoad_Server {


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

        ServerSocket serverSocket = new ServerSocket(10087);

        while (true){
            Socket socket = serverSocket.accept();  //通过服务器的对象 获取客户端的socket

            InputStream is = socket.getInputStream(); //获取客户端的输入流 ，准备接受数据



            String filename=System.currentTimeMillis()+ new Random().nextInt(99999)+".jpg";
            File file = new File("E:\\upload");//创建需要上传文件的文件夹
            if (!file.exists()) {  //如果文件夹不存在
                file.mkdirs();  //创建文件夹
            }

            //创建需要保存文件的输出流，
            FileOutputStream fos = new FileOutputStream(file + "\\"+filename);
            byte[] bytes = new byte[1024];
            int len;
            while ((len = is.read(bytes)) != -1) {  //死循环一直读取消息
                fos.write(bytes, 0, len);
            }

            OutputStream outputStream = socket.getOutputStream(); //获取socket的输入流
            outputStream.write("上传成功".getBytes()); //向客户端发送 上传成功

            /**
             * 三个流都需要关闭，
             * */
            fos.close();
            socket.close();
        }


       // serverSocket.close(); 如果需要服务器一直启动，就不需要关闭serverSocket


    }

}

最后编辑于：2021.05.31 15:11:43

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 213,014评论 6赞 492
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,796评论 3赞 386
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 158,484评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,830评论 1赞 285
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,946评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,114评论 1赞 292
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,182评论 3赞 412
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,927评论 0赞 268
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,369评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,678评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,832评论 1赞 341
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,533评论 4赞 335
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,166评论 3赞 317
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,885评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,128评论 1赞 267
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,659评论 2赞 362
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,738评论 2赞 351

java 中的socket （demo +心跳 +重连）

使用Socket 实现最简单的通讯

简单的通讯 心跳 重连

模拟文件上传

服务端

推荐阅读更多精彩内容

简单的通讯心跳重连