PHP/Java 套接字通信不起作用

Posted

技术标签:

【中文标题】PHP/Java 套接字通信不起作用【英文标题】:PHP/Java socket communication not working 【发布时间】:2015-08-24 06:12:26 【问题描述】:

我已经被以下问题困扰了两天:我编写了一个 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();
    


只要我在 php 中同时调用 sendSocket 和 getResponse 方法,页面就会无限加载。但是,如果我只是分别调用 sendSocket 或 getResponse(在更改 java 套接字之后它不会等待输入)方法,它们就可以正常工作。

我做错了什么?

亲切的问候。

【问题讨论】:

【参考方案1】:

见:http://php.net/manual/en/function.socket-recv.php

MSG_WAITALL 标志将阻塞,直到它收到缓冲区的完整长度。您已将其指定为 2048 字节的数据。

【讨论】:

看来不是这样。我目前正在使用一种解决方法,其中我使用 2 个套接字。 1 用于接收,1 用于发送。我收到长度可变的消息。 当您尝试接收而不发送 php 脚本时会发生什么?当您比较在两个脚本中读取缓冲区的方式时,您是在增量获取 Java 中的缓冲区块,但只是将缓冲区分配给 php 变量。您需要在 php.ini 中采用相同的方法。浏览器在这些连接解决之前不会加载页面,并且您的读取连接似乎保持打开状态,因为它正在等待接收更多数据。浏览器大约在 6 年前开始这样做,而不是在读取它们阻塞的缓冲区时将实时数据传送到页面。 当我收到但没有发送时,我会收到 java 服务器发送的消息,没有任何问题。到目前为止,我所做的解决方法效果很好。我在想如果我在不同的线程中处理发送和接收实际上可能会更好。我会结束这个问题。还是谢谢

以上是关于PHP/Java 套接字通信不起作用的主要内容,如果未能解决你的问题,请参考以下文章

套接字通信在 localhost 中不起作用

从不同线程在同一个套接字上发送和接收不起作用

设置套接字流不起作用

Python异步套接字recv不起作用

在套接字 C++ 中选择不起作用

STOMP 网络套接字回调不起作用