Блог

Я должен реализовать отправку данных с определенного исходного порта и в то же время прослушивать этот порт. Полный дуплекс. Кто-нибудь знает, как это реализовать на Java. Я попытался создать отдельный поток для прослушивания входного потока сокета, но это не работает. Я не могу привязать ServerSocket и клиентский сокет к одному и тому же исходному порту и то же самое с netty. Есть ли какое-либо решение для скучного дуплекса?

     init(){
    socket = new Socket(InetAddress.getByName(Target.getHost()), Target.getPort(), InetAddress.getByName("localhost"), 250);
    in = new DataInputStream(socket.getInputStream());
    out = new DataOutputStream(socket.getOutputStream());
    }

     private static void writeAndFlush(OutputStream out, byte[] b) throws IOException {
        out.write(b);
        out.flush();
      }


    public class MessageReader implements Runnable {

        @Override
        public void run() {
//this method throw exception EOF
          read(in);

          }
private void read(DataInputStream in){
 while (isConnectionAlive()) {
          StringBuffer strBuf = new StringBuffer();
          byte[] b = new byte[1000];
          while ((b[0] = bufferedInputStream.read(b)) != 3) {
            strBuf.append(new String(b));
          }
          log.debug(strBuf.toString());
        }
}
        }
  

То, что вы пытаетесь сделать, довольно странно: ServerSocket это полностью реализованный сокет, который принимает соединения, обрабатывает свои собственные сообщения, и вы определенно не можете подключить к нему другой сокет поверх него.

Полный дуплекс довольно просто выполнить с помощью NIO:

1. Создайте Channel для своего Socket в неблокирующем режиме
2. Добавьте чтение в интересующие операции
3. Переход в спящий режим с помощью метода Selector ‘s select()
4. Считывать любые читаемые байты, записывать любые доступные для записи байты
5. Если запись завершена, удалите запись из интересующих операций
6. ПЕРЕХОД 3.
7. Если вам нужно записать, добавьте байты в буфер, добавьте запись в интересующие операции и активируйте селектор. (немного упрощенный, но я уверен, что вы сможете найти свой путь вокруг Javadoc)

Таким образом, вы будете полностью загружать исходящий буфер каждый раз, когда есть свободное место, и одновременно читать из входящего (ну, в одном потоке, но вам не нужно заканчивать запись, чтобы начать чтение и т.д.).

Я столкнулся с тем же вопросом и решил ответить на него сам. Я хотел бы поделиться с вами, ребята, репозиторием кода. Это действительно просто, вы можете понять, как заставить ваши вещи работать. Это сложный пример. Шаги случайно выглядят как решение Ордуса.

https://github.com/khanhhua/full-duplex-chat

Не стесняйтесь клонировать! Это моя домашняя работа на выходные.

Основной поток:

• Создайте фоновый поток (потоки), который будет подключаться к любым целевым машинам.
  • Эти потоки будут подключаться к целевым машинам, передавать данные и умирать
• Создайте бесконечный цикл
  • Прослушивание входящих подключений.
    • Отключите любое соединение для обработки ввода-вывода

Классы:

• Сервер
  • Прослушивает входящие соединения и потоки от объекта клиента
• Клиент
  • Этот класс создается на сервере, принимающем входящее соединение, TcpClient или NetClient (я забыл, как это называется Java) используется для отправки данных. По завершении он умирает.
• Цель
  • Создается во время запуска и подключается к определенной цели и отправляет данные.
  • после завершения он умирает.