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

网友投稿 246 2023-05-09


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.BufferedOutputStreaHbYiKYGqHm;

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();

}

}

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


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:接口可以实现抽象类吗(接口可以实现抽象类吗为什么)
下一篇:Java8新特性之再见Permgen_动力节点Java学院整理
相关文章

 发表评论

暂时没有评论,来抢沙发吧~