java多人聊天一般都是怎么搭建的？

Java多人聊天可以使用Java的Socket编程实现，主要的思路是：使用服务器来维护所有客户端的连接，并将客户端之间的聊天信息进行转发。巧稿岁

具体的实现步骤如下：

创建服务器端：使用ServerSocket类创建一个服务器端，并监听指定的端口，等待客户端的连接。

创建客户端：使用Socket类创建一个客户端，并连接到服务器端。

实现聊天功能：客户端和服务器端之间可以通过输入和输出流进行通信，客户端将聊天信息发送给服务器，服务器再将其转发给其他客户端。

处理异常：在实现聊天功能时，需要注意处理可能出现的异常，例如连接异常、孝睁输入输出异常等等。

一个简单的Java多人聊天程序的代码框架如下：

服务器端：

import java.io.IOException

import java.net.ServerSocket

import java.net.Socket

import java.util.ArrayList

public class ChatServer {

private ServerSocket serverSocket

private ArrayList<ClientHandler>clients

public ChatServer(int port) throws IOException {

serverSocket = new ServerSocket(port)

clients = new ArrayList<ClientHandler>()

System.out.println("服务器已启动，等敬差待客户端连接...")

}

public void start() throws IOException {

while (true) {

Socket socket = serverSocket.accept()

ClientHandler client = new ClientHandler(socket, this)

clients.add(client)

client.start()

}

}

public void broadcast(String message) {

for (ClientHandler client : clients) {

client.sendMessage(message)

}

}

public void removeClient(ClientHandler client) {

clients.remove(client)

}

public static void main(String[] args) throws IOException {

ChatServer server = new ChatServer(12345)

server.start()

}

}

客户端：

import java.io.BufferedReader

import java.io.IOException

import java.io.InputStreamReader

import java.io.PrintWriter

import java.net.Socket

public class ChatClient {

private Socket socket

private BufferedReader reader

private PrintWriter writer

private String name

public ChatClient(String serverAddress, int port, String name) throws IOException {

socket = new Socket(serverAddress, port)

reader = new BufferedReader(new InputStreamReader(socket.getInputStream()))

writer = new PrintWriter(socket.getOutputStream(), true)

this.name = name

}

public void start() throws IOException {

System.out.println("欢迎来到聊天室！")

new Thread(new IncomingMessageHandler()).start()

new Thread(new OutgoingMessageHandler()).start()

}

private class IncomingMessageHandler implements Runnable {

@Override

public void run() {

try {

while (true) {

String message = reader.readLine()

if (message == null) {

break

}

System.out.println(message)

}

} catch (IOException e) {

e.printStackTrace()

} finally {

close()

}

}

}

private class OutgoingMessageHandler implements Runnable {

@Override

public void run() {

BufferedReader reader = new BufferedReader(new InputStreamReader(System.in))

try {

while (true) {

String message = reader.readLine()

if (message.equals("quit")) {

break

}

writer.println(name + ": " + message)

}

} catch (IOException e) {

e.printStackTrace；

} finally {

close()

}

}

}

制作人: CK.y ，汇成建筑企业管理Q：610089144

仅供参考，大家要学会自己制作，很有成就感的啊！！ 用 Java 作后台，开发一个 C / S 架构的多人聊天程序。首先，设计用户界面。

一、界面设计

界面的元件全部使用 Flash CS3 自带的组件：

首先，放入 TextInput 组件（实例名 input_txt），作为用户输入；

再放入 Button 组件（实例名 submit_btn），用于提交输入的信息；

最后放入 TextArea 组件（实例名 output_txt），显示聊天信息。

二、组件参数初始化

由于客户端代码不是很多，我们这次就写在动作帧上：

// ************ 组件参数初始化 ************

submit_btn.label = "发送并雀消息"

output_txt.editable = false

// 设置各组件中字体的大小

input_txt.setStyle("textFormat", new TextFormat(null, 15))

output_txt.setStyle("textFormat", new TextFormat(null, 15))

submit_btn.setStyle("textFormat", new TextFormat(null, 15, null, true))

// 当按下回车或点击 submit_btn 按钮后调用事件处理函数

submit_btn.addEventListener(MouseEvent.CLICK, sendMessage)

addEventListener(KeyboardEvent.KEY_DOWN, onKeyDown)

// 事件处理函数

function onKeyDown(evt:KeyboardEvent):void {

if (evt.keyCode == Keyboard.ENTER) {

sendMessage(null)

}

}

function sendMessage(evt:Event):void {

// 测试：将 input_txt 的内容输出到 output_txt 中

output_txt.appendText(input_txt.text + "\n")

// 清空 input_txt，并设置焦点到 input_txt

input_txt.text = ""

stage.focus = input_txt

}

三、编写客户端 Socket

1. 首先，Socket 连接非常简单：

var socket:Socket = new Socket()

socket.connect("127.0.0.1", 8888)

其中 connect() 方法中绝咐早的两个参数分别为是主机名和端口号（端口号尽量用 1024 以上）。好了，这样就连接上了。接下来是读写的问题。

2. 向服务器端写入字符串：我们在 sendMessage() 方法中进行写入 *** 作，注意写出的字串必需以回车（\n）结束：

function sendMessage(evt:Event):void {

var bytes:ByteArray = new ByteArray()

bytes.writeUTFBytes(input_txt.text + "\n")

socket.writeBytes(bytes)

socket.flush()

// 清空 input_txt，并设置焦点到 input_txt

input_txt.text = ""

stage.focus = input_txt

}

3. 读取服务器端写回的字符串：最后将服务器发回的字符串输出到 output_txt 文本域中：

// 当客户端 socket 收简手到数据后会调用 readMessage() 函数

socket.addEventListener(ProgressEvent.SOCKET_DATA, readMessage)

function readMessage(evt:ProgressEvent):void {

output_txt.appendText(socket.readUTF() + "\n")

}

四、Flash 客户端全部脚本

// ************ 组件参数初始化 ************

submit_btn.label = "发送消息"

output_txt.editable = false

input_txt.setStyle("textFormat", new TextFormat(null, 15))

output_txt.setStyle("textFormat", new TextFormat(null, 15))

submit_btn.setStyle("textFormat", new TextFormat(null, 15, null, true))

submit_btn.addEventListener(MouseEvent.CLICK, sendMessage)

addEventListener(KeyboardEvent.KEY_DOWN, onKeyDown)

function onKeyDown(evt:KeyboardEvent):void {

if (evt.keyCode == Keyboard.ENTER) {

sendMessage(null)

}

}

function sendMessage(evt:Event):void {

var bytes:ByteArray = new ByteArray()

bytes.writeUTFBytes(input_txt.text + "\n")

socket.writeBytes(bytes)

socket.flush()

input_txt.text = ""

stage.focus = input_txt

}

// ************ 客户端 Socket ************

var socket:Socket = new Socket()

socket.connect("127.0.0.1", 8888)

socket.addEventListener(ProgressEvent.SOCKET_DATA, readMessage)

function readMessage(evt:ProgressEvent):void {

output_txt.appendText(socket.readUTF() + "\n")

}

五、编写 Java 服务器端 Socket

最后，我们需要编写 Java 后台服务器端的代码。

首先，创建一个 ServerSocket 作为Socket 服务器。当有客户端连接后通过 accept() 方法即可得到客户端的 Socket：

ServerSocket socketServer = new ServerSocket(8888)

System.out.println("服务器已启动，等待客户端连接")

// accept() 方法是阻塞式的，当有客户端连接成功后才继续执行

Socket socket = socketServer.accept()

System.out.println("客户端连接成功")

然后得到与客户端的输入流和输出流（输入流是客户端连接到服务器的管道，输出流则是服务器到客户端的管道）：

// 获得输入流和输出流，输入流为 BufferedReader 类型，输出流为 DataOutputStream 类型

BufferedReader reader =

new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"))

DataOutputStream writer = new DataOutputStream(socket.getOutputStream())

拿到输入输出流以后，就可以通过输入流（InputStream）读取 Flash 客户端发来的字符串，通过输出流（OutputStream）向 Flash 客户端写字符串：

while (true) {

// readLine() 方法也是阻塞式的，当客户端有消息发来就读取，否则就一直等待

String msg = reader.readLine()

// 当客户端发送的字符串为 null 时，说明客户端已经关闭，此时退出循环

if (msg == null) {

System.out.println("客户端已离开")

break

}

// 将读入的信息加工后再写回客户端

writer.writeUTF("写回客户端的" + msg)

}

以上是ServerSocket 与 AS 3 Socket 通信的基本原理。在实际应用中，会有多个客户端连接这个ServerSocket，因此要创建一个多线程的 Socket 服务器。

下面简述一下多线程 Socket 服务器原理：当socketServer.accept() 之后就需要实例化一个线程对象，在该对象中持有socketServer.accept() 返回的 Socket 对象，然后让线程跑起来执行读写 *** 作。如果再来一个客户端就再跑一个线程，同样执行读写 *** 作。同时，用一个 List 容器来管理这些对象。

最终服务器端的代码如下：

import java.io.BufferedReader

import java.io.DataOutputStream

import java.io.IOException

import java.io.InputStreamReader

import java.io.UnsupportedEncodingException

import java.net.ServerSocket

import java.net.Socket

import java.util.ArrayList

import java.util.Iterator

import java.util.List

public class FlashScoket {

private List<Client>clientList = new ArrayList<Client>()

public static void main(String[] args) {

new FlashScoket().runSocket()

}

private void runSocket() {

try {

ServerSocket socketServer = new ServerSocket(8888)

System.out.println("服务器已启动，等待客户端连接")

while (true) {

// accept() 方法是阻塞式的，当有客户端连接成功后才继续执行

Socket socket = socketServer.accept()

System.out.println("客户端连接成功")

// 实例化一个 Client 对象，并启动该线程

Client client = new Client(socket)

clientList.add(client)

client.start()

}

} catch (IOException e) {

e.printStackTrace()

}

}

class Client extends Thread {

private Socket socket

private BufferedReader reader

private DataOutputStream writer

private Client(Socket socket) {

this.socket = socket

try {

// 获得输入流和输出流，输入流为 BufferedReader 类型，输出流为 DataOutputStream 类型

reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"))

writer = new DataOutputStream(socket.getOutputStream())

} catch (UnsupportedEncodingException e) {

e.printStackTrace()

} catch (IOException e) {

e.printStackTrace()

}

}

@Override

public void run() {

try {

while (true) {

// readLine() 方法也是阻塞式的，当客户端有消息发来就读取，否则就一直等待

String msg = reader.readLine()

// 当客户端发送的字符串为 null 时，说明客户端已经关闭，此时退出循环

if (msg == null) {

clientList.remove(this)

System.out.println("客户端已离开")

break

}

// 将读入的内容写给每个客户端

for (Iterator<Client>it = clientList.iterator()it.hasNext()) {

Client client = it.next()

client.getWriter().writeUTF(msg)

}

}

} catch (IOException e) {

e.printStackTrace()

} finally {

// 关闭 socket 及相关资源

try {

if (reader != null) {

reader.close()

}

} catch (IOException e) {

e.printStackTrace()

} finally {

try {

if (writer != null) {

writer.close()

}

} catch (IOException e) {

e.printStackTrace()

} finally {

try {

if (socket != null) {

socket.close()

}

} catch (IOException e) {

e.printStackTrace()

}

}

}

}

}

public DataOutputStream getWriter() {

return writer

}

}

}

六、补充技术

1. 如何测试？

* 首先要编译FlashScoket —— javac FlashScoket

* 然后启动FlashScoket —— java FlashScoket

* 最后将 Flash 发布为 exe 文件格式，同时开启多个即可。

2. 自动跟踪到最后一行：当收到新的消息时自动滚动到最后一行，在 readMessage() 方法中加入：

output_txt.verticalScrollBar.scrollPosition = output_txt.verticalScrollBar.maxScrollPosition

3. 当出现输入/输出错误并导致发送或加载 *** 作失败时提示用户，加入对IO_ERROR 的侦听：

socket.addEventListener(IOErrorEvent.IO_ERROR, socketIOError)

function socketIOError(evt:IOErrorEvent):void {

output_txt.appendText("服务器端尚未开启，请稍后再试\n")

}

4. 在sendMessage() 中加入对空字符串的验证，如果为空则 return：

if (input_txt.text == "") {

return

}

5. 在消息前面显示用户名：大家可以制作一个登录页面，输入用户名，假设已将输入的用户名存放在 userName 变量中，在写入时加进去：

var userName:String = "FL 车在臣"

在 sendMessage() 中相应改为：

bytes.writeUTFBytes(userName + " : " + input_txt.text + "\n")

6. 使用output_txt .htmlText 输出文字，那么相应的写入格式可以调整为：

bytes.writeUTFBytes("<font color='#0000FF'>" + userName + " : </font>" + input_txt.text + "\n")

很简单。既然你能写出单聊(也就是P2P)，那多人聊天其实是相似的，只要你了解对方的机器IP和端口号，就可以创建一个套接字去连接。

Socket soc = new Socket()

soc.ConnectToServer()

创建连接就是这样的代码，里面的参数需要指定协议(TCP/UDP),IP及端口，然后客户端就可以使用Socket.Send()方法发消息，服务端收到后，可以用TcpListener.AcceptTcpClient()方法收到客户端的Socket,同样调用Send()方法反馈给客户端。

所谓的UDP丢包或者存在准确率误差情况只是相对的，是一种单纯概念上的理解而已。事实上，哗逗芦在局域网这种稳定的网络环境中，使用UDP是最佳的选择，速度快，且编程较TCP方便。至于所谓的握手，无非是为了网络的检测，用在局域网这种层次的网络真的有必要吗，除非你是为了追求一些时髦的用语和技术。如果要设计握手，那应该是应用层上的协议了，这需要你自己来制定。其实，QQ就采用了UDP协议。乱带

至于端口号，一台机器是不能同时开两个相同的监听端口的，但如果收外部的连接要求，一个端口号足够了。比如你开启了端口号2512(Oracle数据库的默认端口)来处理监听，那其他机器只要连接到这个端口号就能与你通信。还是Oracle为例，一个Oracle服务器可以创建与多个客户端的连接，但端口号也都是2512，这并不矛盾，因为服务器只监听一个端口，但它能指缓收到所有的客户端连接，不知道你明白了吗？

---