Java中的多線程回顯服務器怎么利用Socket實現？相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。
具體如下：
需要兩個類，一個是EchoServer，代表服務器。另外一個是EchoServerClient，代表客戶端。代碼如下：
package interview;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class EchoServer {
public static void main(String []args) throws IOException{
ServerSocket server = new ServerSocket(6789);
while(true){
Socket client = server.accept();
ClientHandler handler = new ClientHandler(client);
new Thread(handler).start();
}
}
public static class ClientHandler implements Runnable{
private Socket client;
@Override
public void run() {
InputStreamReader isr = null;
try {
isr = new InputStreamReader(client.getInputStream());
BufferedReader br = new BufferedReader(isr);
PrintWriter pw = new PrintWriter(client.getOutputStream());
String msg = br.readLine();
System.out.println("收到" + client.getInetAddress() + "發送的" + msg);
pw.println("收到了你發的" + msg);
pw.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
public ClientHandler(Socket client){
this.client = client;
}
}
}下面是客戶端代碼：
package interview;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class EchoServerClient {
public static void main(String []args) throws UnknownHostException, IOException{
Socket client = new Socket("127.0.0.1", 6789);
Scanner sc = new Scanner(System.in);
System.out.print("請輸入要發送的內容：");
String msg = sc.nextLine();
sc.close();
PrintWriter pw = new PrintWriter(client.getOutputStream());
pw.println(msg);
pw.flush();
InputStreamReader isr = new InputStreamReader(client.getInputStream());
BufferedReader br = new BufferedReader(isr);
System.out.println("服務器返回：" + br.readLine());
client.close();
}
}NIO多路復用套接字方法如下：
package interview;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.CharacterCodingException;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.nio.charset.CharsetEncoder;
import java.util.Iterator;
public class EchoServerNIO {
private static ServerSocketChannel serverChannel = null;
private static Selector selector = null;// 多路復用選擇器
private static ByteBuffer buffer = null; // 緩沖區
public static void main(String []args) throws IOException{
init();
listen();
}
static void init() throws IOException{
serverChannel = ServerSocketChannel.open();
buffer = ByteBuffer.allocate(1024);
serverChannel.socket().bind(new InetSocketAddress(6789));
serverChannel.configureBlocking(false);
selector = Selector.open();
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
}
static void listen() throws IOException{
while(true){
if(selector.select(5000) != 0){
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
while(it.hasNext()){
SelectionKey key = it.next();
it.remove();
handleKey(key);
}
}
}
}
static void handleKey(SelectionKey key) throws IOException{
SocketChannel channel = null;
if(key.isAcceptable()){
ServerSocketChannel serverChannel = (ServerSocketChannel)key.channel();
channel = serverChannel.accept();
channel.configureBlocking(false);
channel.register(selector, SelectionKey.OP_READ);
}else if(key.isReadable()){
channel = (SocketChannel)key.channel();
buffer.clear();
if(channel.read(buffer) > 0){
buffer.flip();
CharBuffer charBuffer = CharsetHelper.decode(buffer);
String msg = charBuffer.toString();
System.out.println("收到" + channel.getRemoteAddress() + "的消息:" + msg);
channel.write(CharsetHelper.encode(CharBuffer.wrap("received your msg:" + msg)));
}
}
}
public static class CharsetHelper{
private static final String UTF_8 = "UTF-8";
private static CharsetEncoder encoder = Charset.forName(UTF_8).newEncoder();
private static CharsetDecoder decoder = Charset.forName(UTF_8).newDecoder();
private CharsetHelper() {
}
public static ByteBuffer encode(CharBuffer in) throws CharacterCodingException{
return encoder.encode(in);
}
public static CharBuffer decode(ByteBuffer in) throws CharacterCodingException{
return decoder.decode(in);
}
}
}看完上述內容，你們掌握Java中的多線程回顯服務器怎么利用Socket實現的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
