快捷導(dǎo)航

Java 網(wǎng)絡(luò)編程之 TCP 實現(xiàn)簡單的聊天系統(tǒng)

更新時間：2020年11月20日 09:06:00 作者：Hateyes

這篇文章主要介紹了Java 網(wǎng)絡(luò)編程之 TCP 實現(xiàn)簡單的聊天系統(tǒng)，幫助大家更好的理解和學(xué)習(xí)Java 網(wǎng)絡(luò)編程，感興趣的朋友可以了解下

客戶端

1、連接服務(wù)器 Socket

2、發(fā)送消息

package lesson02;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

/**
 * 客戶端
 */
public class TcpClientDemo1 {

  public static void main(String[] args) {

    Socket socket = null;
    OutputStream os = null;

    try {
      //1、要知道服務(wù)器的地址 端口號
      InetAddress serverIP = InetAddress.getByName("127.0.0.1");
      int port = 9999;
      //2、創(chuàng)建一個 socket 連接
      socket = new Socket(serverIP, port);
      //3、發(fā)送消息 IO流
      os = socket.getOutputStream();
      os.write("你好，歡迎學(xué)習(xí)狂神學(xué)Java".getBytes());

    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      if (os != null){
        try {
          os.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (socket != null){
        try {
          socket.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
  }

}

服務(wù)端

1、建立服務(wù)的端口 ServerSocket

2、等待用戶的連接 accept

3、接收用戶的消息

package lesson02;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服務(wù)端
 */
public class TcpServerDemo1 {

  public static void main(String[] args) {

    ServerSocket serverSocket = null;
    Socket socket = null;
    InputStream is = null;
    ByteArrayOutputStream baos = null;

    try {
      //1、我得有一個地址
      serverSocket = new ServerSocket(9999);

      while (true){
        //2、等待客戶端連接過來
        socket = serverSocket.accept();
        //3、讀取客戶端的消息
        is = socket.getInputStream();

        //管道流
        baos = new ByteArrayOutputStream();
        byte[] buffer = new byte[1024];
        int len;
        while((len = is.read(buffer)) != -1){
          baos.write(buffer, 0 , len);
        }
        System.out.println(baos.toString());
      }

      /*
      byte[] buffer = new byte[1024];
      int len;
      while ((len = is.read(buffer)) != -1){
        String msg = new String(buffer, 0, len);
        System.out.println(msg);
      }
      */

    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      //關(guān)閉資源
      if (baos != null){
        try {
          baos.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (is != null){
        try {
          is.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (socket != null){
        try {
          socket.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (serverSocket != null){
        try {
          serverSocket.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
  }

}

服務(wù)端

1、建立服務(wù)的端口 ServerSocket

2、等待用戶的連接 accept

3、接收用戶的消息

package lesson02;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服務(wù)端
 */
public class TcpServerDemo1 {

  public static void main(String[] args) {

    ServerSocket serverSocket = null;
    Socket socket = null;
    InputStream is = null;
    ByteArrayOutputStream baos = null;

    try {
      //1、我得有一個地址
      serverSocket = new ServerSocket(9999);

      while (true){
        //2、等待客戶端連接過來
        socket = serverSocket.accept();
        //3、讀取客戶端的消息
        is = socket.getInputStream();

        //管道流
        baos = new ByteArrayOutputStream();
        byte[] buffer = new byte[1024];
        int len;
        while((len = is.read(buffer)) != -1){
          baos.write(buffer, 0 , len);
        }
        System.out.println(baos.toString());
      }

      /*
      byte[] buffer = new byte[1024];
      int len;
      while ((len = is.read(buffer)) != -1){
        String msg = new String(buffer, 0, len);
        System.out.println(msg);
      }
      */

    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      //關(guān)閉資源
      if (baos != null){
        try {
          baos.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (is != null){
        try {
          is.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (socket != null){
        try {
          socket.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      if (serverSocket != null){
        try {
          serverSocket.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
  }

}

以上就是Java 網(wǎng)絡(luò)編程之 TCP 實現(xiàn)簡單的聊天系統(tǒng)的詳細內(nèi)容，更多關(guān)于Java 實現(xiàn)簡單的聊天系統(tǒng)的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: