1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. 
   
5. public class tcpserver {
   
6.         public static void main(String[] args) throws Exception {
   
7.                 ServerSocket ss=new ServerSocket(10010);//创建绑定到特定端口的服务器套接字。
   
8.                 while(true){//循环接受连接
   
9.                         Socket s=ss.accept();//侦听并接受到此套接字的连接。
   
10.                 new Thread(new picthread(s)).start();//启动线程实现多连接
    
11.                 }
    
12.         }
    
13.         
    
14. }
    
15. class picthread implements Runnable{
    
16.         private Socket st;
    
17.         picthread(Socket st){
    
18.                 this.st=st;
    
19.         }
    
20.         public void run() {
    
21.         String ip=st.getInetAddress().getHostName();//获得连接主机的ip
    
22.         int num=1;//文件，名变量
    
23.         try {
    
24.                 InputStream in=st.getInputStream();//获得套接字的输入流
    
25.                 File f=new File(ip+"("+num+")"+".jpg");//创建源文件对象
    
26.                 while(f.exists()){//判断是否存在
    
27.                         f=new File(ip+"("+(num++)+")"+".jpg");//自定义的文件命名规则
    
28.                 }
    
29.                 FileOutputStream fos=new FileOutputStream(f);//打开文件输出流，并指定了源文件的文件名和路径
    
30.                 byte[] by=new byte[1024];
    
31.                 int len=0;
    
32.                 while((len=in.read(by))!=-1){
    
33.                         fos.write(by, 0, len);//将数据写入文件
    
34.                 }
    
35.                //System.out.print("!!!!"+ip);//程序运行到此处发生了阻塞，未打印
    
36.                 OutputStream out=st.getOutputStream();//获取套接字的输出流
    
37.                 out.write("上传成功".getBytes());//给连接主机反馈内容
    
38.                 fos.close();//关闭IO流
    
39.                 st.close();//关闭Socket流
    
40.         } catch (IOException e) {
    
41.              throw new RuntimeException(ip+"上传失败");
    
42.         }        
    
43.         }
    
44. }
    

复制代码

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. public class tcpclient{
   
5.         public static void main(String[] args) throws Exception {
   
6.      Socket st= new Socket("127.0.0.1",10010);// 创建一个流套接字并将其连接到指定 IP 地址的指定端口号。
   
7.      FileInputStream fim=new FileInputStream("f:\\01.jpg");//打开文件输入流并指定源文件
   
8.      OutputStream out=st.getOutputStream();//得到套接字的输出流
   
9.      byte[] bt=new byte[1024];
   
10.      int len=0;
    
11.      while((len=fim.read(bt))!=-1){
    
12.              out.write(bt, 0, len);//将源文件数据按指定大小传给输出流
    
13.      }
    
14.      InputStream in=st.getInputStream();//得到套接字的输入流
    
15.      byte[] bti=new byte[1024];
    
16.      int num=in.read(bti);//获得输入流发送的数据长度  
    
17. //程序运行到此处发生了阻塞，未打印
    
18.     System.out.print("通过运行");//未打印
    
19.      System.out.println(new String(bti,0,num));//打印输入流数据
    
20.      fim.close();//关闭IO流
    
21.      st.close();//关闭Socket流
    
22.         }
    
23. }

复制代码

代码如上，客户端运行到socket的接受流、服务端运行到socket的输入流都没有运行了，文件上传能成功，但是客户端在调用in.read()方法时发生了阻塞？而服务器在获取套接字的输出流之前发生了阻塞？两个控制台都没有反应，后面的代码都没有运行了，需要修改什么地方才能实现多个客户端向服务器上传图片？为什么它们没有运行了？

在网吧，我记得是有一条一语是防阻塞的，你修下试试

while((len=fim.read(bt))!=-1){

             out.write(bt, 0, len);//将源文件数据按指定大小传给输出流

     }
在后面加条语句，
st.shutdownOuput()；//这条语句就是说话客户端的输出数据结束，后面 的read方法就不会在阻塞等待读取了

栗学魁 发表于 2012-8-15 14:36
在网吧，我记得是有一条一语是防阻塞的，你修下试试

while((len=fim.read(bt))!=-1){

试过了 还是没用

我把楼主的程序试了一下，就是只要添加一句st.shutdownOuput()；就可以正常运行了呀

王程 发表于 2012-8-15 15:32
我把楼主的程序试了一下，就是只要添加一句st.shutdownOuput()；就可以正常运行了呀 ...

怎么我的还是卡着没动啊、、、

这个真心没招了{:soso_e110:}

徐小骥 发表于 2012-8-15 15:53
怎么我的还是卡着没动啊、、、

okl但是程序为什么会堵塞？

栗学魁 发表于 2012-8-15 14:36
在网吧，我记得是有一条一语是防阻塞的，你修下试试

while((len=fim.read(bt))!=-1){

程序为什么会发生这种堵塞？

这里是因为你的tcpclient里的socket的输出流对应着ServerSocket里面的输入流，而这个输入流里的read（）方法是阻塞是方法，也就是你的当你没有给给这个方法设定一个结束标记时，它就会一直等待，（以为还没有读完），所以就在与其对应的socket里面的输入流的后面加上一句表示符，告诉数据已经输入完毕，这句语句也就是st.shutdownoutput();

程有愿 发表于 2012-8-15 16:39
这里是因为你的tcpclient里的socket的输出流对应着ServerSocket里面的输入流，而这个输入流里的read（）方 ...

明白了，也就是在客户端中我只给文件指定了结束标记，但是没有指定out流的结束标记，所以out一直在运行而in流一直阻塞？

是的呀，呵呵

谢谢，搞清楚了

问题已解决