clienttest.java

这是一个简单的java程序 希望对大家有所帮助

package socket1;

//客户端
import java.awt.*;
import java.awt.Image.*;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;
import javax.swing.JFileChooser;
public class ClientTest {
    private ClientSocket cs = null;

    private String ip = "localhost";// 设置成服务器IP

    private int port =8821;

    private String sendMessage = "Windwos";
    
  String dircter;
  
  
  
  
  class imgframe extends Frame{
	   Image img1;
	   public imgframe(String filename){
		   String s=filename;
		   img1=Toolkit.getDefaultToolkit().getImage(s);
	   }
	   
	   public void paint(Graphics g)
	   {
		   g.drawImage(img1, 0, 0, this);
	   }
  }
  
    public ClientTest() {
       // Frame f=new Frame("接受对话框");
        //FileDialog d1=new FileDialog(f,"选择文件",FileDialog.SAVE);
        JFileChooser file=new JFileChooser();
        file.setFileSelectionMode(JFileChooser.DIRECTORIES_ONLY);
        file.showOpenDialog(new Frame());
        //text1.setText(file.getSelectedFile().getPath());
        //f.show();
        //d1.show();
        dircter=file.getSelectedFile().getPath();
        try {
            if (createConnection()) {
                sendMessage();
                getMessage();
            }

        } catch (Exception ex) {
            ex.printStackTrace();
        }
        
       
    }
  
    private boolean createConnection() {
        cs = new ClientSocket(ip, port);
        try {
            cs.CreateConnection();
            System.out.print("连接服务器成功!" + "\n");
            return true;
        } catch (Exception e) {
            System.out.print("连接服务器失败!" + "\n");
            return false;
        }

    }

    private void sendMessage() {
        if (cs == null)
            return;
        try {
            cs.sendMessage(sendMessage);
        } catch (Exception e) {
            System.out.print("发送消息失败!" + "\n");
        }
    }

    private void getMessage() {
        if (cs == null)
            return;
        DataInputStream inputStream = null;
        try {
            inputStream = cs.getMessageStream();
        } catch (Exception e) {
            System.out.print("接收消息缓存错误\n");
            return;
        }

        try {
            String savePath = dircter;//获取存储路径
            int bufferSize = 8192;
            byte[] buf = new byte[bufferSize];
            int passedlen = 0;
            long len=0;
            
            savePath += inputStream.readUTF();
            DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(new BufferedOutputStream(new FileOutputStream(savePath))));
            len = inputStream.readLong();
            
            System.out.println("文件的长度为:" + len + "\n");
            System.out.println("开始接收文件!" + "\n");
                    
            while (true) {
                int read = 0;
                if (inputStream != null) {
                    read = inputStream.read(buf);
                }
                passedlen += read;
                if (read == -1) {
                    break;
                }
                System.out.println("文件接收了" +  (passedlen * 100/ len) + "%\n");
                fileOut.write(buf, 0, read);
            }
            System.out.println("接收完成，文件存为" + savePath + "\n");
             if(savePath.endsWith(".jpg"))
            		 {
            	        imgframe f=new imgframe(savePath);
            	        f.setSize(1024,800);
            	        f.show();
            	        f.addWindowListener(new WindowAdapter()
            	        {
            	        	public void windowClosing(WindowEvent e)
            	        	{
            	        		System.exit(1);
            	        	}
            	        });
            	     
            		 }
            fileOut.close();
        } catch (Exception e) {
            System.out.println("接收消息错误" + "\n");
            return;
        }
    }

   /* public void start() {
    	
    	new ClientTest(dircter);
		
	}*/

 public static void main(String arg[]) {
        new ClientTest();
    }
}