Java使用TCP实现数据传输实例详解

更新时间：2017年06月08日 15:08:47 作者：Alex_zhuang

这篇文章主要介绍了Java使用TCP实现数据传输实例详解的相关资料,需要的朋友可以参考下

Java使用TCP实现数据传输实例详解

TCP所提供服务的主要特点：

　　1．面向连接的传输；
　　2．端到端的通信；
　　3．高可靠性，确保传输数据的正确性，不出现丢失或乱序；
　　4．全双工方式传输；
　　5．采用字节流方式，即以字节为单位传输字节序列；
　　6．紧急数据传送功能。

TCP传输需要建立客户端和服务器端，即Socket和Server Socket ，建立连接后，通过Socket中的IO流进行数据的传输。传输结束后关闭Socket。

客户端和服务器端是两个独立的应用程序。

以下是实现基本的TCP数据传输的Demo code：

package javase.day18; 
 
import java.io.BufferedReader; 
import java.io.BufferedWriter; 
import java.io.InputStreamReader; 
import java.io.OutputStreamWriter; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
public class TransTextDemo { 
  public static void main(String[] args) { 
  } 
 
} 
 
class TcpClient2{ 
  public static void main(String[] args) throws Exception{ 
    System.out.println("client start..."); 
    Socket s = new Socket("192.168.1.2",10005); 
    BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); 
    BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); 
    String sendDataStr=null; 
    while((sendDataStr=br.readLine())!=null){ 
      if(sendDataStr.equals("bye")){ 
        break; 
      } 
      bw.write(sendDataStr); 
      bw.newLine(); 
      bw.flush(); 
    } 
    bw.close(); 
  } 
} 
 
class TcpServer2{ 
  public static void main(String[] args) throws Exception{ 
    System.out.println("server start..."); 
    ServerSocket ss = new ServerSocket(10005); 
    Socket s = ss.accept(); 
    BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream())); 
    BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); 
    String receiveDataStr=null; 
    while((receiveDataStr=br.readLine())!=null){ 
      if(receiveDataStr.equals("bye")){ 
        break; 
      } 
      System.out.println("receive data:"+receiveDataStr); 
    } 
  } 
}

使用TCP实现文本文件上传的Demo code：

package javase.day18; 
 
import java.io.BufferedReader; 
import java.io.FileReader; 
import java.io.FileWriter; 
import java.io.InputStreamReader; 
import java.io.OutputStreamWriter; 
import java.io.PrintWriter; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
public class UploadText { 
 
  public static void main(String[] args) { 
    // TODO Auto-generated method stub 
 
  } 
} 
 
 
 
class TextServer{ 
  public static void main(String[] args) throws Exception{ 
    System.out.println("Server start..."); 
    ServerSocket ss = new ServerSocket(10008); 
    Socket s = ss.accept(); 
    BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream())); 
    PrintWriter out = new PrintWriter(new FileWriter("C:\\java_test\\server.txt"),true); 
    String line=null; 
    while((line=br.readLine())!=null){ 
      System.out.println(line); 
      out.println(line); 
    } 
     
    PrintWriter pw = new PrintWriter(new OutputStreamWriter(s.getOutputStream()),true); 
    pw.println("upload successful"); 
    pw.close(); 
    s.close(); 
    ss.close(); 
  } 
} 
 
 
class TextClient{ 
  public static void main(String[] args) throws Exception{ 
    System.out.println("Client start..."); 
    Socket clientSocket = new Socket("192.168.1.2",10008); 
    BufferedReader br = new BufferedReader(new FileReader("C:\\java_test\\SystemDemo.java")); 
    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),true); 
    String line=null; 
    while((line=br.readLine())!=null){ 
      System.out.println(line); 
      out.println(line); 
    } 
    clientSocket.shutdownOutput(); 
    BufferedReader br2 = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); 
    String confirmMsgStr=br2.readLine(); 
    System.out.println(confirmMsgStr); 
    br2.close(); 
    clientSocket.close(); 
     
  } 
}

实现图片上传的Demo code：

package javase.day18; 
 
import java.io.BufferedInputStream; 
import java.io.BufferedOutputStream; 
import java.io.FileInputStream; 
import java.io.FileOutputStream; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
public class UploadImage { 
 
  public static void main(String[] args) { 
 
  } 
 
} 
 
class ImageClient{ 
  public static void main(String[] args) throws Exception{ 
    Socket imageClientSocket = new Socket("192.168.1.2",10010); 
    BufferedInputStream bis = new BufferedInputStream(new FileInputStream("C:\\java_test\\client\\生活用品01.jpg")); 
    BufferedOutputStream bos = new BufferedOutputStream(imageClientSocket.getOutputStream()); 
    byte[] buf = new byte[1024*100]; 
    int len = 0 ; 
    while((len=bis.read(buf))!=-1){ 
      bos.write(buf,0,len); 
    } 
    imageClientSocket.shutdownOutput(); 
    BufferedInputStream bis2 = new BufferedInputStream(imageClientSocket.getInputStream()); 
    byte[] buf2 = new byte[1024]; 
    int len2 = 0 ; 
    while((len2=bis2.read(buf2))!=-1){ 
      System.out.println(new String(buf2,0,len2)); 
    } 
    bis.close(); 
    imageClientSocket.close(); 
     
  } 
} 
 
class ImageServer{ 
  public static void main(String[] args) throws Exception{ 
    ServerSocket ss = new ServerSocket(10010); 
    Socket s = ss.accept(); 
    BufferedInputStream bis = new BufferedInputStream(s.getInputStream()); 
    BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("C:\\java_test\\server\\生活用品01.jpg")); 
    byte[] buf = new byte[1024*100]; 
    int len = 0 ; 
    while((len=bis.read(buf))!=-1){ 
      bos.write(buf, 0, len); 
    } 
    BufferedOutputStream bos2 = new BufferedOutputStream(s.getOutputStream()); 
    bos2.write("upload successful".getBytes()); 
    bos2.close(); 
    s.close(); 
    ss.close(); 
  } 
}

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

您可能感兴趣的文章:

解决Springboot @WebFilter拦截器未生效问题
这篇文章主要介绍了解决Springboot @WebFilter拦截器未生效问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-10-10
Maven一键部署Springboot到Docker仓库为自动化做准备(推荐)
这篇文章主要介绍了Maven一键部署Springboot到Docker仓库，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2020-07-07
spring boot配置读写分离的完整实现步骤
数据库配置主从之后，如何在代码层面实现读写分离？所以下面这篇文章主要给大家介绍了关于spring boot配置读写分离的完整步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友可以参考下
2018-09-09
如何使用cmd命令行窗口运行java文件
多年以来一直使用的是IDE来写java项目,导致很多的最基础的东西都渐渐模糊了,最近遇到一个问题就是如果命令行来运行一个java项目,这里总结下,这篇文章主要给大家介绍了关于如何使用cmd命令行窗口运行java文件的相关资料,需要的朋友可以参考下
2023-10-10
java发送post请求使用multipart/form-data格式文件数据到接口代码示例
这篇文章主要介绍了java发送post请求使用multipart/form-data格式文件数据到接口的相关资料,文中指定了数据编码格式为UTF-8,并强调了所需依赖工具类,需要的朋友可以参考下
2024-12-12
java必学必会之线程（1）
java必学必会之线程第一篇，介绍了线程的基本概念、线程的创建和启动，想要学好java线程的朋友一定要好好阅读这篇文章
2015-12-12
Java中判断字符串是中文或者英文的工具类分享
这篇文章主要介绍了Java中判断字符串是中文或者英文的工具类分享,本文直接给出代码,相关说明请看代码的注释,需要的朋友可以参考下
2014-10-10
从ElasticSearch中删除数据的几种常见方式
这篇文章主要给大家介绍了关于从ElasticSearch中删除数据的几种常见方式,在Elasticsearch中删除数据可以通过删除索引或删除文档两种方式实现,需要的朋友可以参考下
2024-10-10
自定义类加载器以及打破双亲委派模型解析
这篇文章主要介绍了自定义类加载器以及打破双亲委派模型解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-11-11
一次"java:程序包org.aspectj.lang不存在"问题解决实战记录
这篇文章主要给大家介绍了一次"java:程序包org.aspectj.lang不存在"问题解决的实战过程,这个错误提示意味着你的Java程序中引用了org.aspectj.lang这个包,但是该包并不存在,文章通过图文介绍的非常详细,需要的朋友可以参考下
2023-06-06

Java使用TCP实现数据传输实例详解

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具