最近做了一個(gè)項(xiàng)目，其中有一個(gè)在線網(wǎng)頁交流的需求，好久沒寫代碼了，手都生疏了，于是先寫demo練練手，分享到腳本之家平臺(tái)，以此做個(gè)記錄，方便自己和大家使用。

先給大家說下實(shí)現(xiàn)步驟分這樣幾大步：

1、使用awt組件和socket實(shí)現(xiàn)簡(jiǎn)單的單客戶端向服務(wù)端持續(xù)發(fā)送消息；

2、結(jié)合線程，實(shí)現(xiàn)多客戶端連接服務(wù)端發(fā)送消息；

3、實(shí)現(xiàn)服務(wù)端轉(zhuǎn)發(fā)客戶端消息至所有客戶端，同時(shí)在客戶端顯示；

4、把a(bǔ)wt組件生成的窗口界面改成前端jsp或者h(yuǎn)tml展示的界面，java socket實(shí)現(xiàn)的客戶端改為前端技術(shù)實(shí)現(xiàn)。

這里首先實(shí)現(xiàn)第一步的簡(jiǎn)單功能，難點(diǎn)在于：

1、沒有用過awt組件，沒有用過java相關(guān)的監(jiān)聽事件；

2、長(zhǎng)時(shí)間沒有使用socket進(jìn)行客戶端和服務(wù)端的交互，并且沒有真正進(jìn)行過cs結(jié)構(gòu)的開發(fā)。

實(shí)現(xiàn)功能的代碼如下：

客戶端：

package chat.chat;

import java.awt.BorderLayout;

import java.awt.Frame;

import java.awt.TextArea;

import java.awt.TextField;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.Socket;

import java.net.UnknownHostException;

/**

* 在線聊天客戶端 1、生成圖形窗口界面輪廓 2、為輪廓添加關(guān)閉事件 3、在輪廓中加入輸入?yún)^(qū)域和內(nèi)容展示區(qū)域 4、為輸入?yún)^(qū)域添加回車事件

* 5、建立服務(wù)端連接并發(fā)送數(shù)據(jù)

*

* @author tuzongxun123

*

*/

public class ChatClient extends Frame {

// 用戶輸入?yún)^(qū)域

private TextField tfTxt = new TextField();

// 內(nèi)容展示區(qū)域

private TextArea tarea = new TextArea();

private Socket socket = null;

// 數(shù)據(jù)輸出流

private DataOutputStream dataOutputStream = null;

public static void main(String[] args) {

new ChatClient().launcFrame();

}

/**

* 建立一個(gè)簡(jiǎn)單的圖形化窗口

*

* @author：tuzongxun

* @Title: launcFrame

* @param

* @return void

* @date May 18, 2016 9:57:00 AM

* @throws

*/

public void launcFrame() {

setLocation(300, 200);

this.setSize(200, 400);

add(tfTxt, BorderLayout.SOUTH);

add(tarea, BorderLayout.NORTH);

pack();

// 監(jiān)聽圖形界面窗口的關(guān)閉事件

this.addWindowListener(new WindowAdapter() {

@Override

public void windowClosing(WindowEvent e) {

System.exit(0);

disConnect();

}

});

tfTxt.addActionListener(new TFLister());

setVisible(true);

connect();

}

/**

* 連接服務(wù)器

*

* @author：tuzongxun

* @Title: connect

* @param

* @return void

* @date May 18, 2016 9:56:49 AM

* @throws

*/

public void connect() {

try {

// 新建服務(wù)端連接

socket = new Socket("127.0.0.1", 8888);

// 獲取客戶端輸出流

dataOutputStream = new DataOutputStream(socket.getOutputStream());

System.out.println("連上服務(wù)端");

} catch (UnknownHostException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 關(guān)閉客戶端資源

*

* @author：tuzongxun

* @Title: disConnect

* @param

* @return void

* @date May 18, 2016 9:57:46 AM

* @throws

*/

public void disConnect() {

try {

dataOutputStream.close();

socket.close();

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 向服務(wù)端發(fā)送消息

*

* @author：tuzongxun

* @Title: sendMessage

* @param @param text

* @return void

* @date May 18, 2016 9:57:56 AM

* @throws

*/

private void sendMessage(String text) {

try {

dataOutputStream.writeUTF(text);

dataOutputStream.flush();

} catch (IOException e1) {

e1.printStackTrace();

}

}

/**

* 圖形窗口輸入?yún)^(qū)域監(jiān)聽回車事件

*

* @author tuzongxun123

*

*/

private class TFLister implements ActionListener {

@Override

public void actionPerformed(ActionEvent e) {

String text = tfTxt.getText().trim();

tarea.setText(text);

tfTxt.setText("");

// 回車后發(fā)送數(shù)據(jù)到服務(wù)器

sendMessage(text);

}

}

}

服務(wù)端：

package chat.chat;

import java.io.DataInputStream;

import java.io.EOFException;

import java.io.IOException;

import java.net.BindException;

import java.net.ServerSocket;

import java.net.Socket;

/**

* java使用socket和awt組件簡(jiǎn)單實(shí)現(xiàn)在線聊天功能服務(wù)端 可以實(shí)現(xiàn)一個(gè)客戶端連接后不斷向服務(wù)端發(fā)送消息

* 但不支持多個(gè)客戶端同時(shí)連接，原因在于代碼中獲得客戶端連接后會(huì)一直循環(huán)監(jiān)聽客戶端輸入，造成阻塞

* 以至于服務(wù)端無法二次監(jiān)聽另外的客戶端，如要實(shí)現(xiàn)，需要使用異步或者多線程

*

* @author tuzongxun123

*

*/

public class ChatServer {

public static void main(String[] args) {

// 是否成功啟動(dòng)服務(wù)端

boolean isStart = false;

// 服務(wù)端socket

ServerSocket ss = null;

// 客戶端socket

Socket socket = null;

// 服務(wù)端讀取客戶端數(shù)據(jù)輸入流

DataInputStream dataInputStream = null;

try {

// 啟動(dòng)服務(wù)器

ss = new ServerSocket(8888);

} catch (BindException e) {

System.out.println("端口已在使用中");

// 關(guān)閉程序

System.exit(0);

} catch (Exception e) {

e.printStackTrace();

}

try {

isStart = true;

while (isStart) {

boolean isConnect = false;

// 啟動(dòng)監(jiān)聽

socket = ss.accept();

System.out.println("one client connect");

isConnect = true;

while (isConnect) {

// 獲取客戶端輸入流

dataInputStream = new DataInputStream(

socket.getInputStream());

// 讀取客戶端傳遞的數(shù)據(jù)

String message = dataInputStream.readUTF();

System.out.println("客戶端說：" + message);

}

}

} catch (EOFException e) {

System.out.println("client closed!");

} catch (Exception e) {

e.printStackTrace();

} finally {

// 關(guān)閉相關(guān)資源

try {

dataInputStream.close();

socket.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

以上所述是小編給大家介紹的Java Socket實(shí)現(xiàn)一個(gè)簡(jiǎn)易在線聊天功能(一)的相關(guān)知識(shí)，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

總結(jié)

以上是生活随笔為你收集整理的简单java socket_基于Java Socket实现一个简易在线聊天功能（一）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。