java實現(xiàn)簡易聊天功能

更新時間：2022年09月15日 14:12:00 作者：數(shù)據(jù)結(jié)構(gòu)做不對

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

本文實例為大家分享了java實現(xiàn)簡易聊天功能的具體代碼，供大家參考，具體內(nèi)容如下

應(yīng)用客戶端和服務(wù)端通過控制臺的輸入輸出實現(xiàn)簡易聊天功能

思路：

1.創(chuàng)建服務(wù)端類ChatServerThread和客戶端類ChatClientThradd

2.創(chuàng)建發(fā)送類Sendlmpl和接收類Receivelmpl

3.在服務(wù)端類中監(jiān)聽8888號端口，并開啟發(fā)送和接收線程

4.在客戶端類中連接8888號端口并開啟發(fā)送和接收線程

5.在發(fā)送類中，開啟線程循環(huán)，發(fā)送用戶輸入的信息

6.在接收類中，開啟線程循環(huán)，接收網(wǎng)絡(luò)發(fā)送的數(shù)據(jù)

代碼實現(xiàn)

服務(wù)端ChatServerThread

package test;

import java.net.ServerSocket;
import java.net.Socket;

public class ?ChatServerThread{
? ? //服務(wù)端
? ? public static void main(String[] args) throws Exception{
? ? ? ? ServerSocket serverSocket = new ServerSocket(8888);
? ? ? ? //監(jiān)聽8888號端口
? ? ? ? Socket socket = serverSocket.accept();
? ? ? ? //開啟發(fā)送和接收線程
? ? ? ? Sendlmpl sendlmpl=new Sendlmpl(socket);
? ? ? ? new Thread(sendlmpl).start();
? ? ? ? Receivelmpl receivelmpl=new Receivelmpl(socket);
? ? ? ? new Thread(receivelmpl).start();
? ? }
}

客戶端ChatClientThradd

package test;

import test.Receivelmpl;
import test.Sendlmpl;

import java.net.Socket;

public class ChatClientThradd {
? ? //客戶端
? ? public static void main(String[] args) throws Exception{
? ? ? ? //連接8888號端口
? ? ? ? Socket socket=new Socket("127.0.0.1",8888);
? ? ? ? //開啟發(fā)送和接收線程
? ? ? ? Sendlmpl sendlmpl=new Sendlmpl(socket);
? ? ? ? new Thread(sendlmpl).start();
? ? ? ? Receivelmpl receivelmpl=new Receivelmpl(socket);
? ? ? ? new Thread(receivelmpl).start();
? ? }
}

發(fā)送類Sendlmpl ：

package test;

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

public class Sendlmpl implements Runnable {
? ? //發(fā)送類
? ? private Socket socket;

? ? public Sendlmpl(Socket socket) {
? ? ? ? this.socket = socket;
? ? }

? ? @Override
? ? public void run() {
? ? ? ? Scanner scanner = new Scanner(System.in);
? ? ? ? //線程循環(huán)，發(fā)送用戶輸入的信息
? ? ? ? while (true) {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? OutputStream outputStream =socket.getOutputStream();
? ? ? ? ? ? ? ? String string=scanner.nextLine();
? ? ? ? ? ? ? ? outputStream.write(string.getBytes());
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

接收類Receivelmpl ：

package test;

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

public class Receivelmpl implements Runnable{
? ? //接收類
? ? private Socket socket;

? ? public Receivelmpl(Socket socket) {
? ? ? ? this.socket = socket;
? ? }

? ? @Override
? ? public void run() {
? ? ? ? //循環(huán)接收網(wǎng)絡(luò)發(fā)來的信息
? ? ? ? while (true) {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? InputStream inputStream=socket.getInputStream();
? ? ? ? ? ? ? ? byte [] bytes=new byte[1024];
? ? ? ? ? ? ? ? int z=inputStream.read(bytes);
? ? ? ? ? ? ? ? System.out.println(new String(bytes,0,z));
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

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

您可能感興趣的文章: