android Socket實(shí)現(xiàn)簡(jiǎn)單聊天功能以及文件傳輸

Socket(InetAddress address,int port); //創(chuàng)建一個(gè)流套接字并將其連接到指定 IP 地址的指定端口號(hào)
Socket(String host,int port); //創(chuàng)建一個(gè)流套接字并將其連接到指定主機(jī)上的指定端口號(hào)
Socket(InetAddress address,int port, InetAddress localAddr,int localPort); //創(chuàng)建一個(gè)套接字并將其連接到指定遠(yuǎn)程地址上的指定遠(yuǎn)程端口
Socket(String host,int port, InetAddress localAddr,int localPort); //創(chuàng)建一個(gè)套接字并將其連接到指定遠(yuǎn)程主機(jī)上的指定遠(yuǎn)程端口
Socket(SocketImpl impl); //使用用戶指定的 SocketImpl 創(chuàng)建一個(gè)未連接 Socket

public InputStream getInputStream(); //方法獲得網(wǎng)絡(luò)連接輸入，同時(shí)返回一個(gè)IutputStream對(duì)象實(shí)例
public OutputStream getOutputStream(); //方法連接的另一端將得到輸入，同時(shí)返回一個(gè)OutputStream對(duì)象實(shí)例
public Socket accept(); //用于產(chǎn)生"阻塞"，直到接受到一個(gè)連接，并且返回一個(gè)客戶端的Socket對(duì)象實(shí)例。

ServerSocket(int port); //創(chuàng)建綁定到特定端口的服務(wù)器套接字
ServerSocket(int port,int backlog); //利用指定的 backlog 創(chuàng)建服務(wù)器套接字并將其綁定到指定的本地端口號(hào)
ServerSocket(int port,int backlog, InetAddress bindAddr); //使用指定的端口、偵聽 backlog 和要綁定到的本地 IP地址創(chuàng)建服務(wù)器

    try {
      Socket socket = new Socket("173.1.1.121", 30004);

      //獲取控制臺(tái)輸入的內(nèi)容
      BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
      System.out.print("請(qǐng)輸入發(fā)送的字符串：");
      String str = bufferedReader.readLine();

      //給服務(wù)端發(fā)送消息
      PrintWriter printWriter = new PrintWriter(socket.getOutputStream());
      printWriter.write(str + "\r\n");
      printWriter.flush();

      //關(guān)閉資源
      bufferedReader.close();
      printWriter.close();
      socket.close();
    } catch (IOException e) {
      e.printStackTrace();
    }

   InetAddress ia = null;
   try {
     ia = ia.getLocalHost();
     String localname = ia.getHostName();
     String localip = ia.getHostAddress();
     System.out.println("本機(jī)名稱是：" + localname);
     System.out.println("本機(jī)的ip是 ：" + localip);
   } catch (Exception e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
   }

    try {
      mServerSocket = new java.net.ServerSocket(30004);

      Socket socket = mServerSocket.accept();

      BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

      String content = null;
      while ((content=bufferedReader.readLine() )!= null) {
        System.out.println("接收到客服端發(fā)來的消息：" +content);
      }

      //關(guān)閉連接
      bufferedReader.close();
      socket.close();

    } catch (IOException e) {
      e.printStackTrace();
    }

  //文件名稱
  public String fileName;

  //文件長(zhǎng)度
  public long fileLength;

  //傳輸類型
  public int transmissionType;

  //傳輸內(nèi)容
  public String content;

  //傳輸?shù)拈L(zhǎng)度
  public long transLength;

  //發(fā)送還是接受類型  1發(fā)送 2接收
  public int itemType = 1;

  //0 文本 1 圖片
  public int showType;

  /**
   * 文件路徑
   *
   * @param filePath
   */
  private void sendFile(String filePath) {
    FileInputStream fis = null;
    File file = new File(filePath);

    try {
      mSendHandler.sendEmptyMessage(Constants.PROGRESS);

      fis = new FileInputStream(file);

      Transmission trans = new Transmission();
      trans.transmissionType = Constants.TRANSFER_FILE;
      trans.fileName = file.getName();
      trans.fileLength = file.length();
      trans.transLength = 0;

      byte[] bytes = new byte[1024];
      int length = 0;
      while ((length = fis.read(bytes, 0, bytes.length)) != -1) {
        trans.transLength += length;
        trans.content = Base64Utils.encode(bytes);
        mPrintWriter.write(mGson.toJson(trans) + "\r\n");
        mPrintWriter.flush();

        //更新進(jìn)度
        Message message = new Message();
        message.what = Constants.PROGRESS;
        message.obj = 100 * trans.transLength / trans.fileLength;
        mSendHandler.sendMessage(message);
      }
      fis.close();
    } catch (FileNotFoundException e) {
      e.printStackTrace();
      if (fis != null) {
        try {
          fis.close();
        } catch (IOException e1) {
          e1.printStackTrace();
        }
      }
    } catch (IOException e) {
      e.printStackTrace();
      mPrintWriter.close();
    }
  }

    trans.content = Base64Utils.encode(bytes);
    mPrintWriter.write(mGson.toJson(trans) + "\r\n");
    mPrintWriter.flush();

    long fileLength = trans.fileLength;
    long transLength = trans.transLength;
    if (mCreateFile) {
      mCreateFile = false;
      fos = new FileOutputStream(new File("d:/" + trans.fileName));
    }
    byte[] b = Base64Utils.decode(trans.content.getBytes());
    fos.write(b, 0, b.length);
    System.out.println("接收文件進(jìn)度" + 100 * transLength / fileLength + "%...");
    if (transLength == fileLength) {
      mCreateFile = true;
      fos.flush();
      fos.close();
    }