黑马程序员技术交流社区

标题: 求解答 [打印本页]
作者: longyun    时间: 2016-6-3 22:30
标题: 求解答
使用socket编写一个Java程序，要求：客户端上传图片到服务端，服务端接收完毕后存放到本地，并发送“接收完毕”的信息到客户端，客户端在控制台显示接收的情况?
作者: 18611643318    时间: 2016-6-3 22:58
  1. package com.itheima;

  3. import java.io.BufferedReader;
  4. import java.io.BufferedWriter;
  5. import java.io.FileInputStream;
  6. import java.io.FileOutputStream;
  7. import java.io.InputStream;
  8. import java.io.InputStreamReader;
  9. import java.io.OutputStream;
  10. import java.io.OutputStreamWriter;
  11. import java.net.ServerSocket;
  12. import java.net.Socket;

  14. /**
  15. * 8、使用TCP协议写一个可以上传文件的服务器和客户端。
  16. * @author Venus
  17. *
  18. */
  19. public class Test8 {
  20.         public static void main(String[] args) {
  21.                 //启动一个新的线程,调用服务器的服务
  22.                 new Thread() {
  23.                         public void run() {
  24.                                 try {
  25.                                         Server.server();
  26.                                 } catch (Exception e) {
  27.                                         // TODO Auto-generated catch block
  28.                                         e.printStackTrace();
  29.                                 }
  30.                         }
  31.                 }.start();
  32.                 //当前线程,调用客户端的上传方法
  33.                 try {
  34.                         new Client().upload();
  35.                 } catch (Exception e) {
  36.                         // TODO Auto-generated catch block
  37.                         e.printStackTrace();
  38.                 }
  39.                
  40. }
  41. }
  42. //客户端  
  43. class Client        {
  44.   
  45.     public static void upload() throws Exception {  
  46.     //建立Socket服务  ,传入参数服务器的ip和端口号
  47.     Socket Socket = new Socket("127.0.0.1", 9527);  
  48.     //从客户端本地读取文件,并写入socket的输出流中  
  49.     OutputStream out = Socket.getOutputStream();  
  50.     //实例化对象fileReader
  51.     InputStream fileRead = new FileInputStream("D:\\1.txt");  
  52.     //建立数组
  53.     byte[] buf = new byte[1024];  
  54.     int len = 0;
  55.     //判断是否读到文件末尾
  56.     while((len=fileRead.read(buf)) != -1)
  57.         {  
  58.          out.write(buf, 0, len);  
  59.         }  
  60.     //断开socket  
  61.     Socket.shutdownOutput();  
  62.     //获取从服务端反馈的信息  
  63.     BufferedReader in = new BufferedReader(new InputStreamReader(Socket.getInputStream()));  
  64.     String serverBack = in.readLine();  
  65.     System.out.println(serverBack);   
  66.     //资源关闭  
  67.     Socket.close();  
  68.     fileRead.close();  
  69.   }  
  70. }  

  72. //服务端  
  73. class Server {  
  74.    public static void server() throws Exception {  
  75.     //建立服务端Socket  
  76.     ServerSocket ss = new ServerSocket(9527);  
  77.     //接收客户端Socket  
  78.     Socket fileLoaderSocket = ss.accept();  
  79.       
  80.     //打印连接信息  
  81.     String ip = fileLoaderSocket.getInetAddress().getHostAddress();  
  82.     System.out.println(ip + "...conncected");  
  83.       
  84.     //接收文件，并保存  
  85.     InputStream in = fileLoaderSocket.getInputStream();  
  86.     //实例化对象fileSave
  87.     OutputStream fileSave = new FileOutputStream("D:\\2.txt");  
  88.     //建立数组buf
  89.     byte[] buf = new byte[1024];  
  90.     int len = 0;  
  91.     //判断是否读到文件末尾
  92.      while((len=in.read(buf)) != -1)
  93.        {  
  94.         fileSave.write(buf, 0, len);  
  95.         //刷新
  96.         fileSave.flush();  
  97.        }  
  98.     //返回文件复制情况信息  
  99.     BufferedWriter out = new BufferedWriter(new OutputStreamWriter(fileLoaderSocket.getOutputStream()));  
  100.     out.write("文件上传成功");  
  101.     //刷新
  102.     out.flush();  
  103.     //资源关闭  
  104.     ss.close();  
  105.     fileLoaderSocket.close();  
  106.     fileSave.close();  
  107.   }  
  108. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2