ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

JAVA TCP结合线程使用

2022-04-17 16:03:38  阅读:136  来源: 互联网

标签:JAVA Socket java TCP bw 线程 import new public


package Inter;

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

public class ServeDemo {
    public static void main(String[] args) throws IOException {
       ServerSocket ss = new ServerSocket(10000);
       while (true){
           Socket s = ss.accept();
           new Thread(new ServerThread(s)).start();
       }

    }
}
package Inter;

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

public class ServerThread implements Runnable {
    private Socket s;
    public ServerThread(Socket s) {
    this.s = s;
    }

    @Override
    public void run() {
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
            int count = 0;
            File file = new File("./cc_" + count + ".txt");
            while (file.exists()){
                count++;
                file = new File("./cc_" + count + ".txt");
            }
            BufferedWriter bw = new BufferedWriter(new FileWriter(file));
            String line;
            while ((line=br.readLine()) != null){
                bw.write(line);
                bw.newLine();
                bw.flush();
            }
            BufferedWriter brw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            brw.write("文件上传成功!");
            brw.newLine();
            brw.flush();
        }catch (IOException e){
            e.printStackTrace();
        }
    }
}
package Inter;

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


public class ClientDemo {
    public static void main(String[] args) throws IOException {
        Socket s = new Socket("127.0.0.1",10000);
//
        BufferedReader br = new BufferedReader(new FileReader("./1.txt"));
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line=br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        s.shutdownOutput();
        BufferedReader bu = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line1 = bu.readLine();
        System.out.println("服务器反馈:"+line1);
        bu.close();
        bw.close();
        br.close();
    }
}

 

标签:JAVA,Socket,java,TCP,bw,线程,import,new,public
来源: https://www.cnblogs.com/phpwyl/p/16155976.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有