websocket通信でブラウザ↔︎Wi-Fi子機をリアルタイム通信システムを開発しました。

bugle
├─hardware                ハードウェアに対してコンパイルするプログラミングです。
│  └─wifi
│          wifi.ino         arduinoマイコンボードによって実装しました。こちらのファイルをコンパイルします。
│
└─server                  サーバ側に設置するフォルダです。index.phpをapacheのDocummentrootとします。
    │  index.php            ホームとなるページです。
    │  style.css
    │
    ├─bin
    │      chat-server.php  サーバにて常時稼働させるwebsocket serverです。phpコマンドにて実行してください。
    │      udp-socket.php   udpにてwifi子機と通信するためのudp serverです。phpコマンドにて実行してください。
    │
    └─src
    │   └─Chat.php          bin\chat-server.phpで受信したwebsocketデータを処理するプログラムです。
    │
    └─vendor         phpライブラリであるRatchetを利用させて頂いております。ratchet(https://github.com/ratchetphp/Ratchet)

/*  ___   ___  ___  _   _  ___   ___   ____ ___  ____  
 * / _ \ /___)/ _ \| | | |/ _ \ / _ \ / ___) _ \|    \ 
 *| |_| |___ | |_| | |_| | |_| | |_| ( (__| |_| | | | |
 * \___/(___/ \___/ \__  |\___/ \___(_)____)___/|_|_|_|
 *                  (____/ 
 * Osoyoo Wifi IoT  lesson 2
 * Remote control LED over UDP
 * tutorial url: https://osoyoo.com/?p=10000
 */

#include "WiFiEsp.h"
#include "WiFiEspUdp.h"
#include "SoftwareSerial.h"
#define ledPin 13
#define buzzer 9  //buzzer connect to D9
#define pullupSwitch 7

static const char *kRemoteIpadr = "****";
static const int kRmoteUdpPort = 5051;
unsigned long myTime = 0;
unsigned long BugleTimeoutTimer = 0;
unsigned long CountMyTime = 0;

SoftwareSerial softserial(4, 5); // A9 to ESP_TX, A8 to ESP_RX by default
char ssid[] = "****";            // your network SSID (name)
char pass[] = "****";        // your network password
int status = WL_IDLE_STATUS;     // the Wifi radio's status
WiFiEspUDP Udp;
unsigned int localPort = 8888;              // local port to listen on
char packetBuffer[5];
 
void setup() {
  //pinMode Configration
  pinMode(ledPin,OUTPUT);
  pinMode(buzzer, OUTPUT);
  pinMode(pullupSwitch, INPUT_PULLUP);
  digitalWrite(buzzer,HIGH);

  Serial.begin(9600);   // initialize serial for debugging
    softserial.begin(115200);
  softserial.write("AT+CIOBAUD=9600\r\n");
  softserial.write("AT+RST\r\n");
  softserial.begin(9600);    // initialize serial for ESP module
  WiFi.init(&softserial);    // initialize ESP module

  // check for the presence of the shield:
  if (WiFi.status() == WL_NO_SHIELD) {
    Serial.println("WiFi shield not present");
    // don't continue:
    while (true);
  }

  // attempt to connect to WiFi network
  while ( status != WL_CONNECTED) {
    Serial.print("Attempting to connect to WPA SSID: ");
    Serial.println(ssid);
    // Connect to WPA/WPA2 network
    status = WiFi.begin(ssid, pass);
  }
  
  Serial.println("Connected to wifi");
  printWifiStatus();
 
  // if you get a connection, report back via serial:
  Udp.begin(localPort);
  
  Serial.print(" target port ");
  Serial.println(localPort);
     
}
 
void loop() {
  int pullupSwitch_value = digitalRead( pullupSwitch );//test
  int ledPin_value = digitalRead( ledPin );//test
      myTime = millis() / 1000; //秒数を格納
  int packetSize = Udp.parsePacket();
  if (packetSize) {                               // if you get a client,
     Serial.print("Received packet of size ");
    Serial.println(packetSize);
    int len = Udp.read(packetBuffer, 255);
    if (len > 0) {
      packetBuffer[len] = 0;
    }
      char c=packetBuffer[0];
      switch (c)    //serial control instructions
      {  
 
        case 'F': 
        digitalWrite(ledPin, HIGH); //TURN ON LED
        digitalWrite(buzzer,LOW); //buzzer ON
        BugleTimeoutTimer = myTime;
        break;
        
        case 'G':
        digitalWrite(ledPin, LOW); //TURN OFF LED
        digitalWrite(buzzer,HIGH);//buzzer OFF
        BugleTimeoutTimer = 0;
        CountMyTime = 0;
        break;
 
        default:break;
      }
    }

  if (BugleTimeoutTimer){
    CountMyTime = myTime;
  }

//    Serial.print("Received packet of size ");
//    Serial.println(myTime);
  
  if(pullupSwitch_value == LOW && ledPin_value == HIGH){
    Serial.print("bugle Responded. ");
    
    digitalWrite(ledPin,LOW); //TURN OFF LED
    digitalWrite(buzzer,HIGH);//buzzer OFF

    Udp.beginPacket(kRemoteIpadr,kRmoteUdpPort);
    Udp.write("STOP");
    Udp.endPacket();  
    
  }else if( (CountMyTime-BugleTimeoutTimer) >= 30 ){
    CountMyTime = BugleTimeoutTimer = 0;
    Serial.print("bugle not respond. ");
    
    digitalWrite(ledPin,LOW); //TURN OFF LED
    digitalWrite(buzzer,HIGH);//buzzer OFF

    Udp.beginPacket(kRemoteIpadr,kRmoteUdpPort);
    Udp.write("NON");
    Udp.endPacket();
    
  }
 
}

void printWifiStatus()
{
  // print the SSID of the network you're attached to
  Serial.print("SSID: ");
  Serial.println(WiFi.SSID());

  // print your WiFi shield's IP address
  IPAddress ip = WiFi.localIP();
  Serial.print("IP Address: ");
  Serial.println(ip);
  
  // print where to go in the browser
  Serial.println();
  Serial.print("please set your UDP APP target IP to: ");
  Serial.print(ip);
 
}

<?php
namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use \PDO;

class Chat implements MessageComponentInterface {
    protected $clients;
    public $send_from;
 
    public function __construct() {
        $this->clients = new \SplObjectStorage;
        $this->send_from = 0;
        $this->test = 0;
    }
 
    public function onOpen(ConnectionInterface $conn) {
        // Store the new connection to send messages to later
        $this->clients->attach($conn);
 
        echo "New connection! ({$conn->resourceId})\n";
    }
 
    public function onMessage(ConnectionInterface $from, $msg) {
        $numRecv = count($this->clients) - 1;
            
            $this->send_from = $from; //ローカル関数udpstatus_loop()用に送信用オブジェクトをストックする。
            $pieces = explode(",",$msg);//クライアントから送信されたメッセージを分解して格納する。
            
            $pdo = new PDO('mysql:host=localhost;dbname=bugle;charset=utf8','staff','password');
            $sql = $pdo->prepare('update wifi_machine set client_status=? where INET_NTOA(ip_address) = ?');
            if($pieces[1] == "F"){
                $sql->execute(["呼出要求",$pieces[0]]);//データベースに呼出要求中フラグ格納
            }else if($pieces[1] == "G"){
                $sql->execute(["取消要求",$pieces[0]]);//データベースに呼出要求中フラグ格納
            }

            foreach($pdo->query('select * from wifi_machine') as $row){
                if(long2ip($row['ip_address']) == $pieces[0] && ($row['client_status'] == "呼出要求" or $row['client_status'] == "取消要求")){
                    echo("webブラウザから " . long2ip($row['ip_address']). " に " . $row['client_status'] . PHP_EOL . PHP_EOL);
                    break;
                }
            }

        if ($pieces[1] == "F" || $pieces[1] == "G"){
            $socket = socket_create(AF_INET,SOCK_DGRAM,SOL_UDP);
            $len = strlen($pieces[1]);//クライアントからの実送信メッセージ格納
            socket_sendto($socket,$pieces[1],$len,0,$pieces[0],8888);
        }
        $pdo = null;
    }
 
    public function onClose(ConnectionInterface $conn) {
        // The connection is closed, remove it, as we can no longer send it messages
        $this->clients->detach($conn);
 
        echo "Connection {$conn->resourceId} has disconnected\n";
    }
 
    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";
 
        $conn->close();
    }

    public function udpstatus_loop(){
        $pdo =new PDO('mysql:host=localhost;dbname=bugle;charset=utf8','staff','password');
        $sql = $pdo->prepare('update wifi_machine set client_status=? where INET_NTOA(ip_address) = ?');
        foreach($pdo->query('select * from wifi_machine') as $row){
            if($row['client_status'] == "停止要求"){
                $this->send_from->send(long2ip($row['ip_address']) . " STOP" );
                $sql->execute([null,long2ip($row['ip_address'])]);
                echo("クライアントからの次操作受信開始" . PHP_EOL);
            }else if($row['client_status'] == "応答無"){
                $this->send_from->send(long2ip($row['ip_address']) . " NON" );
                $sql->execute([null,long2ip($row['ip_address'])]);
                echo("クライアントからの次操作受信開始" . PHP_EOL);
            }
        }
        $pdo = null;
    }

}

<?php

function udpsocket_loop(){
        //ここでデータベースの値であるブラウザからの送信状態を読み取って、送信をしている場合処理実行

	    $pdo =new PDO('mysql:host=localhost;dbname=bugle;charset=utf8','staff','password');
		
	    error_reporting(E_ALL | E_STRICT);
	    $udp_port = 5051;
   
	    //UDPのソケット作成
	    $udp_socket = socket_create(AF_INET,SOCK_DGRAM,SOL_UDP);
	    socket_bind($udp_socket,'****',$udp_port);

	//socket_set_nonblock($udp_socket);//socket_recvfrom()にてノンブロッキングでudp受信
	    echo("データ受信開始 : ");
	    while(true){

		    //socket_recvfrom()にてUDPのソケットを受信
		    socket_recvfrom($udp_socket,$udp_buf,50,0,$wifi_from,$wifi_port);
			echo "リモートアドレス $wifi_from のポート $wifi_port から $udp_buf を受信" . PHP_EOL;

			$sql = $pdo->prepare('update wifi_machine set client_status=? where INET_NTOA(ip_address) = ?');
			// $sql->execute(["呼出停止",$wifi_from]);//データベースに呼出停止フラグ格納
		    foreach($pdo->query('select * from wifi_machine') as $row){
				if(long2ip($row['ip_address']) == $wifi_from && $udp_buf == "STOP"){
					if($row['client_status'] == "呼出要求"){
						$sql->execute(["停止要求",$wifi_from]);
						echo($wifi_from . " より停止要求". PHP_EOL. PHP_EOL);
					}
					break;
				}else if(long2ip($row['ip_address']) == $wifi_from && $udp_buf == "NON"){
					if($row['client_status'] == "呼出要求"){
						$sql->execute(["応答無",$wifi_from]);
						echo($wifi_from . " より応答無". PHP_EOL. PHP_EOL);
					}
					break;
				}
			}

		   $wifi_from = "";
		   $wifi_port = "";
		   $udp_buf = "";
		   echo("次のudpデータ受信開始 : ");
	    }

	    //lose socket
	    socket_close($udp_socket);
   
}

udpsocket_loop();

?>