快捷導(dǎo)航

java實(shí)現(xiàn)簡單TCP聊天程序

更新時(shí)間：2021年07月04日 10:42:17 作者：yubo_725

這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)簡單TCP聊天程，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了java實(shí)現(xiàn)TCP聊天程序的具體代碼，供大家參考，具體內(nèi)容如下

服務(wù)端代碼：

package com.test.server;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
 
public class Server {
 
 public static void main(String[] args) {
 new Server().startServer();
 }
 
 public void startServer(){
 try {
  //服務(wù)器在9990端口監(jiān)聽客戶端的連接
  ServerSocket ss = new ServerSocket(9999);
  System.out.println("server is listening...");
  while(true){
  //阻塞的accept方法，當(dāng)一個(gè)客戶端連接上，才會(huì)返回Socket對象
  Socket s = ss.accept();
  System.out.println("a client has connected!");
  //開啟線程處理通信
  new CommunicateThread(s).start();
  }
 } catch (IOException e) {
  e.printStackTrace();
 }
 }
 
 public class CommunicateThread extends Thread{
 
 Socket socket;
 DataInputStream dis;
 DataOutputStream dos;
 
 public CommunicateThread(Socket socket){
  this.socket = socket;
  try {
  dis = new DataInputStream(socket.getInputStream());
  dos = new DataOutputStream(socket.getOutputStream());
  } catch (IOException e) {
  e.printStackTrace();
  }
 }
 
 @Override
 public void run() {
  super.run();
  //讀取客戶端發(fā)過來的消息
  String msg = null;
  try {
  while((msg = dis.readUTF()) != null){
   System.out.println("client send msg ：" + msg);
   String replyMsg = "server reply ： " + msg;
   dos.writeUTF(replyMsg);
   System.out.println("server reply msg ：" + replyMsg);
  }
  } catch (IOException e) {
  e.printStackTrace();
  }
 }
 }
 
}

客戶端代碼：

package com.test.client;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
 
public class Client {
 
 public static void main(String[] args) {
 new Client().startClient();
 }
 
 public void startClient(){
 try {
  //連接到服務(wù)器
  Socket socket = new Socket("localhost", 9999);
  DataInputStream dis = new DataInputStream(socket.getInputStream());
  DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
  Scanner scanner = new Scanner(System.in);
  String line = null;
  listenServerReply(dis);
  while((line = scanner.nextLine()) != null){//讀取從鍵盤輸入的一行
  dos.writeUTF(line);//發(fā)給服務(wù)端
  System.out.println("client send msg : " + line);
  }
 } catch (Exception e) {
  e.printStackTrace();
 }
 }
 
 //監(jiān)聽服務(wù)端回復(fù)的消息
 public void listenServerReply(final DataInputStream dis){
 new Thread(){
  @Override
  public void run() {
  super.run();
  String line = null;
  try {
   while((line = dis.readUTF()) != null){
   System.out.println("client receive msg from server: " + line);
   }
  } catch (IOException e) {
   e.printStackTrace();
  }
  }
 }.start();
 }
 
}

先啟動(dòng)服務(wù)端，再啟動(dòng)客戶端，在客戶端的控制臺(tái)輸入消息并回車，就可以發(fā)送消息給客戶端了，客戶端收到消息后，馬上會(huì)回復(fù)一個(gè)消息

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: