大佬教程收集整理的这篇文章主要介绍了java 网络编程之TCP通信和简单的文件上传功能实例,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
TCP通信需要明确的几点:
TCP通信是面向连接的,需要先启动服务端,再启动客户端。
客户端和服务端都要创建套接字对象,客户端需要指定服务端套接字(ip+port),而服务端必须指定服务端口。
Socket clIEnt_socket = new Socket("192.168.100.17",8888); //客户端套接字(Socket类的套接字为已连接套接字) ServerSocket Listen_socket = new ServerSocket(8888); //服务端套接字,此时为监听套接字(已经bind()地址和端口了)
服务端需要使用accept()方法将监听套接字转变为已连接套接字。这个监听套接字可以生成多个已连接套接字,这样连接后还能监听其他客户端的请求。因此,这里应该使用多线程实现并发访问。获得了已连接套接字,就可以获取很多客户端的信息,例如客户端的ip地址,发送请求的端口等。
Socket server_scoket = socket.accept(); Socket server_scoket2 = socket.accept(); Socket server_scoket3 = socket.accept();
服务端要实现并发连接,大致使用如下代码:其中ThreadTask是线程任务对象。
public static voID main(String[] args) throws IOException { ServerSocket Listen_sock = new ServerSocket(8888); //监听套接字只需创建一个,因此在任务之外 while (true) { //每建立一个连接,就开启一个线程 Socket conn_sock = Listen_sock.accept(); //没有新连接进来时,main主线程阻塞在此 new Thread(new ThreadTask(conn_sock)).start(); } }
客户端需要根据已连接套接字获取输出流,服务端需要根据套接字获取输入流。当然,既然有了已连接套接字,那么获取无论哪一端都可以获取到输入流、输出流。
OutputStream send_stream = clIEnt_socket.getoutputStream(); //客户端获取输出流 inputStream recv_stream = server_socket.geTinputStream();
服务端应主动关闭已连接套接字,至于监听套接字则在合适的地方关闭。
服务端应该循环不断地负责接收。
简单的ClIEnt端:
import java.io.IOException; import java.io.outputStream; import java.net.socket; public class TCPClIEnt { public static voID main(String[] args) { // 1.创建客户端套接字 Socket c_sock = null; OutputStream clIEnt_outstream = null; try { c_sock = new Socket("192.168.0.124",8888); // 2.获取输出流 clIEnt_outstream = c_sock.getoutputStream(); // 3.输出数据 clIEnt_outstream.write("Hello,i'm coming".getBytes()); } catch (IOException E) { e.printstacktrace(); } finally { if(c_sock != null){ try{ c_sock.close(); } catch(IOException E) { e.printstacktrace(); } } } } }
简单的Server端:
import java.io.bufferedReader; import java.io.IOException; import java.io.inputStream; import java.io.inputStreamReader; import java.net.ServerSocket; import java.net.socket; public class Tcpserver { public static voID main(String[] args) { // 1.创建监听套接字 ServerSocket Listen_sock = null; try { Listen_sock = new ServerSocket(8888); } catch(IOException i) { i.printstacktrace(); } Socket server_sock = null; inputStream in_sock = null; while (true) { try { // 2.和客户端建立连接,生成已连接套接字,并获取客户端ip地址 server_sock = Listen_sock.accept(); String clIEnt_ip = server_sock.geTinetAddress().getHostAddress(); Sy@R_404_6563@.out.println("ClIEnt: " + clIEnt_ip + " connected"); // 3.根据已连接套接字,获取输入流,读取客户端发送的数据 in_sock = server_sock.geTinputStream(); BufferedReader bufr = new BufferedReader(new inputStreamReader(in_sock)); String line = null; while ((line = bufr.readline()) != null) { Sy@R_404_6563@.out.println(linE); } // 4.关闭已连接套接字 server_sock.close(); } catch (IOException E) { e.printstacktrace(); } } } }
以下是tcp实现文件上传功能:
客户端除了套接字的输出流,还有读取本地文件的输入流,还有套接字的输入流来读取来自服务端的反馈信息。
服务端也同样有三流:套接字的输入、输出流,写入上传目标文件的输出流。
客户端读取本地文件的所有数据后,需要使用套接字的shutdownOutput()来通知服务端套接字的输出流已到末尾。
服务端为了能为多人提供上传功能,需要使用多线程实现并发连接。
ClIEnt端:
import java.io.bufferedReader; import java.io.fileinputStream; import java.io.IOException; import java.io.inputStream; import java.io.inputStreamReader; import java.io.outputStream; import java.net.socket; public class UploadClIEnt { public static voID main(String[] args) { // Todo auto-generated method stub String server_addr = "192.168.0.124"; int server_port = 8888; Socket send_sock = null; fileinputStream local_read = null; try { // 1.客户端套接字 send_sock = new Socket(server_addr,server_port); // 2.获取连接管道的输出流 OutputStream send_stream = send_sock.getoutputStream(); // 3.字节输入流读取本地文件数据,并使用套接字的输出流发送出去 local_read = new fileinputStream("d:/myjava/net/sql.docx"); byte[] buf = new byte[1024]; int len = 0; while ((len = local_read.read(buf)) != -1) { send_stream.write(buf,len); } // 4.标记输出流到结尾 send_sock.shutdownOutput(); // 5.接收服务端的反馈数据,如上传成功,上传失败等 inputStream recv_stream = send_sock.geTinputStream(); BufferedReader ack_recv = new BufferedReader(new inputStreamReader(recv_stream)); String line = null; while ((line = ack_recv.readline()) != null) { Sy@R_404_6563@.out.println(linE); } } catch (IOException i) { i.printstacktrace(); } finally { if (send_sock != null) { try { send_sock.close(); local_read.close(); } catch (IOException i1) { i1.printstacktrace(); } } if (local_read != null) { try { local_read.close(); } catch (IOException i2) { i2.printstacktrace(); } } } } }
Server端:
import java.io.file; import java.io.fiLeoutputStream; import java.io.IOException; import java.io.inputStream; import java.io.outputStream; import java.net.ServerSocket; import java.net.socket; public class UploadServer { public static voID main(String[] args) throws IOException { ServerSocket Listen_sock = new ServerSocket(8888); //监听套接字只需创建一个,因此在任务之外 while (true) { //每建立一个连接,就开启一个线程 Socket conn_sock = Listen_sock.accept(); //没有新连接进来时,main主线程阻塞在此 new Thread(new Uploader(conn_sock)).start(); } } } class Uploader implements Runnable { private file dest_dir = new file("d:/temp"); // 上传目录 private Socket conn_sock = null; // 连接套接字 inputStream recv_stream = null; fiLeoutputStream dest_stream = null; Uploader(Socket conn_sock) throws IOException { this.conn_sock = conn_sock; } public voID run() { try { if (!dest_dir.exists()) { dest_dir.mkdirs(); } // 1.获取连接管道的输入流 recv_stream = conn_sock.geTinputStream(); // 客户端ip String clIEnt_ip = conn_sock.geTinetAddress().getHostAddress(); Sy@R_404_6563@.out.println(clIEnt_ip + ".....connected"); // 2.文件的上传位置,即输出目标,以ip命名。如果文件已存在,则使用括号加数字新建文件,如"192.168.100.23(1).txt" file dest_file = new file(dest_dir,clIEnt_ip + ".docx"); int count = 1; while (dest_file.exists()) { dest_file = new file(dest_dir,clIEnt_ip + "(" + count + ")" + ".docx"); count++; } // 3.读取数据并写入目标文件 dest_stream = new fiLeoutputStream(dest_filE); byte[] buf = new byte[1024]; int len = 0; while ((len = recv_stream.read(buf)) != -1) { dest_stream.write(buf,len); } // 4. 向客户端反馈信息 OutputStream ack_send = conn_sock.getoutputStream(); byte[] text = "upload successful!".getBytes(); ack_send.write(text); } catch (IOException e1) { e1.printstacktrace(); } finally { if (dest_stream != null) { try { dest_stream.close(); } catch (IOException i) { i.printstacktrace(); } } if (conn_sock != null) { try { conn_sock.close(); } catch (IOException i) { i.printstacktrace(); } } } } }
以上这篇java 网络编程之TCP通信和简单的文件上传功能实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持编程小技巧。
以上是大佬教程为你收集整理的java 网络编程之TCP通信和简单的文件上传功能实例全部内容,希望文章能够帮你解决java 网络编程之TCP通信和简单的文件上传功能实例所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。