想用JAVA做一个服务器，请问怎么利用TCP和线程，实现多个客户端同时在线，能与服务器进行交互？

服务器监听端口 做个无限循环 接到一个连接就创建一个通道线程，并将通道线程存储到一个list集合中

import javaioBufferedReader;
import javaioIOException;
import javaioInputStreamReader;
import javaioPrintWriter;
import javanetServerSocket;
import javanetSocket;
import javatextSimpleDateFormat;
import javautilArrayList;
import javautilDate;
import javautilList;
/
  4用socket通讯写出多个客户端和一个服务器端的通讯，
  要求客户发送数据后能够回显相同的数据（回显功能）（实用TCP方式）。
 /
public class Test4Server {


// 主入口
public static void main(String[] args) throws IOException {
scoketServer();
}
// 开启的tcp8888监听端口
public static void scoketServer() throws IOException {
ServerSocket server = new ServerSocket(8888);
while (true) {
// 未连通前线程阻塞，连通后开启一个socket通道线程后继续监听8888端口
Socket socket = serveraccept();
Systemoutprintln(socketgetInetAddress()getHostAddress()
+ "连接进入");
new SocketThread(socket)start();
}
}


}
// 一个服务器端口中监听多个客服端通道线程
class SocketThread extends Thread {
//  所有通道写入流的集合
private static List<PrintWriter> list =new ArrayList<PrintWriter>();

private BufferedReader bufferedReader;
private PrintWriter printWriter;
public SocketThread(Socket socket) throws IOException {
thisbufferedReader = new BufferedReader(new InputStreamReader(socket
getInputStream()));
thisprintWriter = new PrintWriter(socketgetOutputStream());
listadd(printWriter);
}
@Override
public void run() {
String string = null;
while (true) {
try {
// 服务器在通道中读到的信息回显给客服端
string = bufferedReaderreadLine();
Systemoutprintln("客服端信息：" + string);
for(PrintWriter printWriter:list ){
printWriterwrite("服务器回显：" + string + "\r\n");
printWriterflush();
}
} catch (IOException e) {
}
}
}
}

客服端代码   可以用在局域网中用多台来连接测试

import javaioBufferedReader;
import javaioIOException;
import javaioInputStreamReader;
import javaioPrintWriter;
import javanetSocket;
import javautilScanner;
public class Test4Client {
public static Object obj = new Object();
// 客服端的主入口
public static void main(String[] args) throws IOException {
socketClient();
}
// 与服务器连通地址本机（127001），局域网中其他机器是（服务器在局域网中的ip地址） 端口都是8888
public static void socketClient() throws IOException {
Socket socket = new Socket("127001", 8888);
if (socketisConnected()) {
// 如果连接成功了就开启写和读的进程
new writer(socket)start();
new read(socket)start();
} else {
Systemoutprintln("服务器未开启");
}
}
}
// 写入到通道的线程
class writer extends Thread {
@SuppressWarnings("unused")
private Socket socket;
private PrintWriter printWriter;
private Scanner scanner = new Scanner(Systemin);
private String str = null;
public writer(Socket socket) throws IOException {
thissocket = socket;
thisprintWriter = new PrintWriter(socketgetOutputStream());
}
@Override
public void run() {
scanneruseDelimiter("\r\n");
while (true) {
Systemoutprint("请输入信息：");
// 产生扫描器的线程阻塞
str = scannernext();
Systemoutprintln("我说："+str);
printWriterwrite(str + "\r\n");
printWriterflush();
try {
Threadsleep(200);
} catch (InterruptedException e) {
eprintStackTrace();
}
}
}
}
// 从通道中读取的线程
class read extends Thread {
private Socket socket;
private BufferedReader bufferedReader;
private String str = null;
public read(Socket socket) throws IOException {
thissocket = socket;
thisbufferedReader = new BufferedReader(new InputStreamReader(socket
getInputStream()));
}
@Override
public void run() {
while (true) {
try {
str = bufferedReaderreadLine();
Systemoutprintln(str);
} catch (IOException e) {
}
try {
Threadsleep(200);
} catch (InterruptedException e) {

eprintStackTrace();
}
}
}
}

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

具体的实现步骤如下：

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

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

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

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

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

服务器端：

import javaioIOException;

import javanetServerSocket;

import javanetSocket;

import javautilArrayList;

public class ChatServer {

private ServerSocket serverSocket;

private ArrayList<ClientHandler> clients;

public ChatServer(int port) throws IOException {

serverSocket = new ServerSocket(port);

clients = new ArrayList<ClientHandler>();

Systemoutprintln("服务器已启动，等待客户端连接");

}

public void start() throws IOException {

while (true) {

Socket socket = serverSocketaccept();

ClientHandler client = new ClientHandler(socket, this);

clientsadd(client);

clientstart();

}

}

public void broadcast(String message) {

for (ClientHandler client : clients) {

clientsendMessage(message);

}

}

public void removeClient(ClientHandler client) {

clientsremove(client);

}

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

ChatServer server = new ChatServer(12345);

serverstart();

}

}

客户端：

import javaioBufferedReader;

import javaioIOException;

import javaioInputStreamReader;

import javaioPrintWriter;

import javanetSocket;

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(socketgetInputStream()));

writer = new PrintWriter(socketgetOutputStream(), true);

thisname = name;

}

public void start() throws IOException {

Systemoutprintln("欢迎来到聊天室！");

new Thread(new IncomingMessageHandler())start();

new Thread(new OutgoingMessageHandler())start();

}

private class IncomingMessageHandler implements Runnable {

@Override

public void run() {

try {

while (true) {

String message = readerreadLine();

if (message == null) {

break;

}

Systemoutprintln(message);

}

} catch (IOException e) {

eprintStackTrace();

} finally {

close();

}

}

}

private class OutgoingMessageHandler implements Runnable {

@Override

public void run() {

BufferedReader reader = new BufferedReader(new InputStreamReader(Systemin));

try {

while (true) {

String message = readerreadLine();

if (messageequals("quit")) {

break;

}

writerprintln(name + ": " + message);

}

} catch (IOException e) {

eprintStackTrace；

} finally {

close();

}

}

}

使用bukkit需调用java以创建服务器。具体步骤如下：
1、下载并安装JRE。
2、在bukkit文件处（推荐放入文件夹）打开控制台，或创建bat或cmd文件，输入启动代码。代码形式：java -Xincgc -Xmx1G -jar craftbukkit-X-Yjar。其中，-Xmx1G为最大内存设置，craftbukkit-X-Yjar为bukkit文件名。
3、运行指令或指令文件，出现“Done!”字样后关闭。
4、若MC版本为1710及以上，则打开目录下生成的eulatxt文件，同意协议后将false改为true。
5、按照自己的需求修改serverproperties文件中的内容与在目录下plugins文件夹添加插件并修改配置文件，注意在修改文件时保持格式。
6、再次按照2中步骤运行指令，出现“Done!”字样则创建服务器成功，若不成功则按错误信息进行查错，之后重试。

---

linux中如何实现用java写一个>

欢迎分享，转载请注明来源：内存溢出

原文地址:https://54852.com/zz/10394386.html