Простой пример клиент-сервер с java nio
Не могли бы вы показать мне небольшой пример на localhost клиента и сервера, которые обмениваются данными с использованием java nio? Мне нужно понять, как это работает java nio. Например 1) клиент требует подключения, клиент подключается, клиент отправляет «Привет, я клиент». 2) Сервер принимает, сервер получает сообщение от клиента, сервер отвечает «привет, я сервер» 3) Клиент отправляет «привет, сервер» 4) Сервер отправляет «привет, клиент».
Мне не нужен сервер для одновременной обработки нескольких клиентов, мне нужно понимать, как происходит соединение с несколькими сообщениями между клиентом и сервером.
Ответы 2
Вы можете использовать следующие ссылки для доступа к вашим требованиям https://www.geeksforgeeks.org/socket-programming-in-java/https://www.journaldev.com/741/java-socket-programming-server-client
Не совсем уверен, зачем вам использовать nio, если вы не собираетесь обрабатывать несколько подключений. Не вижу смысла в их использовании.
Хорошо, дайте мне знать, если это сработает.
Код сервера:
public class Server {
ServerSocket socket;
Socket listener;
public Server(int port) throws IOException {
socket = new ServerSocket(port);
}
public void connect() throws IOException{
listener = socket.accept();
}
public String read() throws IOException{
byte[] temp = new byte[1024];
int bytesRead = 0;
try(InputStream input = listener.getInputStream()){
bytesRead = input.read(temp);
}
return new String(temp,0,bytesRead,"ASCII");
}
public void write(String data) throws IOException{
byte[] temp = new byte[1024];
try(OutputStream out = listener.getOutputStream()){
out.write(data.getBytes());
out.flush();
}
}
public void close(){
socket.close();
}
}
Код клиента:
public class Client{
Socket client;
InetSocketAddress addr;
public Client(String ip, int port) throws IOException{
client = new Socket();
addr = new InetSocketAddress(ip,port);
}
public void connect() throws IOException{
client.connect(addr);
}
public String read() throws IOException{
byte[] temp = new byte[1024];
int bytesRead = 0;
try(InputStream input = client.getInputStream()){
bytesRead = input.read(temp);
}
return new String(temp,0,bytesRead,"ASCII");
}
public void write(String data) throws IOException{
byte[] temp = new byte[1024];
try(OutputStream out = client.getOutputStream()){
out.write(data.getBytes());
out.flush();
}
}
public void close(){
client.close();
}
}
Теперь все, что вам нужно сделать, это вызвать connect () на сервере, затем connect () на клиенте и написать и отправить сообщения, которые вы хотите.
Не забудьте закричать после того, как все закончите.
Также имейте в виду, что вам понадобится какой-то механизм, чтобы сообщить серверу и клиенту, как долго будут длиться каждое сообщение. Или вы можете указать конечный символ, который сообщает клиенту / серверу, что сообщение окончено.
Одна отправка на сервере не обязательно равна одной операции чтения на клиенте, и наоборот. Вам нужно будет выяснить, что делать.