Не работает связь с сокетом PHP / Java

Я застрял в течение двух дней со следующей проблемой: я написал сервер сокетов Java, который может получать и отправлять данные в сокет, размещенный по адресу «localhost: 64005». Я могу подключиться к нему через php и отправлять или получать сообщения. Однако я не могу отправить, а затем получить ответ. Я отследил проблему до написанного мной php-скрипта.

<?php
class socketCommunication{
protected $PK;
protected $ip = '127.0.0.1';
protected $port = 64005;
protected $socket;
public $result;

function __construct($key){
$this->socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socket\n");
$this->result = socket_connect($this->socket, $this->ip, $this->port) or die("Could not connect to server\n");
$this->PK = $key;
$this->sendSocket();
}

function getResponse(){
//$input =  socket_read($this->socket, 1024) or die("Could not read");
$bytes = socket_recv($this->socket, $buf, 2048, MSG_WAITALL);
return $buf;
}

function sendSocket(){
$len = strlen($this->PK);
socket_send ($this->socket, $this->PK, $len, 0);
}
}
?>

<?php
//include("/mysql/RandomQuery.php");
include("/java/socketCommunication.php");

$object2 = new socketCommunication(100001);
echo $object2->getResponse();
?>

сервер сокетов Java:

package Server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.concurrent.Semaphore;

import Database.Reader;

public class Receive implements Runnable {
Semaphore semaphore;
private Socket connection;
String result = "default";

public Receive(Socket conn, Semaphore sem){
this.connection = conn;
this.semaphore = sem;
}

@Override
public void run() {
try {
semaphore.acquire();
System.out.println(connection.toString());
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
PrintWriter out = new PrintWriter(connection.getOutputStream(), true);
String userInput;
while ((userInput = in.readLine()) != null) {
System.out.println(userInput);
Reader reader = new Reader(Integer.parseInt(userInput));
this.result = reader.getResult();
System.out.println(result);
out.println(result);
break;
}
connection.close();
in.close();
System.out.println("input is closed");
semaphore.release();
} catch (IOException | InterruptedException e) {e.printStackTrace();}
}

}

Как только я вызываю оба метода sendSocket и getResponse в php, страница продолжает загружаться бесконечно. Однако, если я просто вызываю метод sendSocket или getResponse (после изменения java-сокета, чтобы он не ожидал ввода), они по отдельности работают нормально.

Что я делаю неправильно?

С уважением.

4

Решение

Увидеть: http://php.net/manual/en/function.socket-recv.php

Флаг MSG_WAITALL будет блокироваться, пока он не получит полную длину буфера. Который вы указали как 2048 байт данных.

1

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]