回答編集履歴

別解掲載

2022/04/21 07:21

投稿

thkana

スコア7639

test CHANGED Viewed

@@ -1,229 +1,170 @@
+2022年4月現在で'ESP32 複数 クライアント'でググったらこれがトップでヒットしちゃって...ちょっと恥ずかしいかな。
+普通にArduinoライブラリでもできちゃったので、一応そちらも載せておきます。二口分の受け方は「ベタ」に書いているので、実際になにかするなら美しくまとめてください。もちろん、動作中にreadStringUntil()とかでブロックしたりしちゃいけませんよ。
+```Arduino
+#include <WiFi.h>
+WiFiServer server(54321);
+void setup() {
+    Serial.begin(115200);
+    WiFi.begin(); //引数省略で最後に接続したAPにつなぎに行く。WiFiの接続とソケットの接続を混同しないようにしましょう。
+    while (WiFi.status() != WL_CONNECTED) {
+        delay(500);
+    }
+    Serial.println(WiFi.localIP());
+    server.begin();
+}
+WiFiClient client[2];
+String s[2];
+void loop() {
+  if( !client[0].connected()){
+    client[0]= server.available();
+    if(client[0].connected()){
+      Serial.println("Connected to 0");
+      client[0].println("Connected to 0");
+    }
+  }else{
+    while(client[0].available()){
+      char c=client[0].read();
+      s[0]+=c;
+      if(c=='\n'){
+        Serial.println(s[0]);
+        client[0].print(s[0]);
+      }
+    }
+  }
+  if( !client[1].connected()){
+    client[1]= server.available();
+    if(client[1].connected()){
+      Serial.println("Connected to 1");
+      client[1].println("Connected to 1");
+    }
+  }else{
+    while(client[1].available()){
+      char c=client[1].read();
+      s[1]+=c;
+      if(c=='\n'){
+        Serial.println(s[1]);
+        client[1].print(s[1]);
+      }
+    }
+  }
+}
+```
+以下原文
+---
 既存のライブラリを真面目に探せばもっといい処理もできそうな気がしますが、見つからなかったので原始的にやってみました。WiFiを繋いだあとはCでソケットを扱う場合の定番にほぼ沿ったものです。
 ```Arduino
 #include <sys/select.h>
 #include <sys/socket.h>
 #include <WiFi.h>
 static const char *WIFI_SSID = "WROOM32";
 static const char *WIFI_PASS = "password";
 const int port = 1337;
 int fd, maxfd;
 int fd2[2] = { -1, -1}; //二口だけ接続をうけつける
 struct sockaddr_in addr;
 struct sockaddr_in from_addr;
 struct timeval tv;
 //サーバー設定-------------------------------------------------
 IPAddress ip(192, 168, 1, 10);
 //-------------------------------------------------------------
 void setup() {
   Serial.begin(115200);
   //Wi-Fiアクセスポイント開始--------------------------------------------------------
   WiFi.mode(WIFI_AP);
   WiFi.softAP(WIFI_SSID, WIFI_PASS);
   WiFi.softAPConfig(ip, WiFi.gatewayIP(), WiFi.subnetMask());
   //WiFi.softAPConfig(ip, gateway, netmask);
   IPAddress myIP = WiFi.softAPIP();
   Serial.println("APStarted. myIP Address:");
   Serial.println(myIP);
   Serial.print("server Mac Address: ");
   Serial.println(WiFi.macAddress());
   Serial.print("Subnet Mask: ");
   Serial.println(WiFi.subnetMask());
   Serial.print("Gateway IP: ");
   Serial.println(WiFi.gatewayIP());
   //------------------------------------------------------------------------------
   if ( (fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
     Serial.println("socket error.");
     while (1);
   }
   addr.sin_family = AF_INET;
   addr.sin_port = ntohs(port);
   addr.sin_addr.s_addr = INADDR_ANY;
   if ( bind( fd, (struct sockaddr *)&addr, sizeof(addr)) < 0 ) {
     Serial.println( "bind error" );
     while (1);
   }
 }
 void loop() {
   if ( listen(fd, 1) < 0) {
     Serial.println("listen error.");
   }
+  fd_set fds;
+  FD_ZERO(&fds);
+  FD_SET( fd, &fds);
+  maxfd = fd;
+  for (int i = 0; i < 2; i++) {
+    if (fd2[i] != -1) {
+      FD_SET(fd2[i], &fds);
+      if (fd2[i] > fd) {
+        maxfd = fd2[i];
+      }
+    }
+  }
+  tv.tv_sec = 0;
+  tv.tv_usec = 10000;
+  int cnt = select(maxfd + 1, &fds, NULL, NULL, &tv);
+  if (cnt <= 0) {
+    //error or timeout
+    for (int i = 0; i < 2; i++) {
+      if (fd2[i] >= 0) {
+      //既接続のソケットに対して送信
+        char buf[32];
+        cnt = sprintf(buf, "To %d %ld\n", fd2[i], millis());
+        write(fd2[i], buf, cnt);
+      }
+    }
+  }
+  if (FD_ISSET( fd, &fds)) {
+    for (int i = 0; i < 2; i++) {
+      //接続受付
+      if (fd2[i] == -1) {
+        socklen_t len = sizeof(struct sockaddr_in);
+        if ((fd2[i] = accept(fd, (struct sockaddr *)&from_addr, &len)) < 0) {
+          Serial.println("accept error.");
+          while (1);
+        }
+        Serial.println("connect " + String( fd2[i]));
+        break;
+      }
+    }
+  }
+  for (int i = 0; i < 2; i++) {
+    if (fd2[i] != -1 && FD_ISSET(fd2[i], &fds) ) {
+      //受信&接続断検出
+      char buf[256];
+      int rcvCnt = recv(fd2[i], buf, sizeof(buf), 0);
+      Serial.println("rcvd:" + String(buf));
+      if (rcvCnt < 0) {
+        Serial.println("disconnect " + String(fd2[i]));
+        close(fd2[i]);
+        fd2[i] = -1;
+      }
+    }
+  }
+}
+```
-  fd_set fds;
-  FD_ZERO(&fds);
-  FD_SET( fd, &fds);
-  maxfd = fd;
-  for (int i = 0; i < 2; i++) {
-    if (fd2[i] != -1) {
-      FD_SET(fd2[i], &fds);
-      if (fd2[i] > fd) {
-        maxfd = fd2[i];
-      }
-    }
-  }
-  tv.tv_sec = 0;
-  tv.tv_usec = 10000;
-  int cnt = select(maxfd + 1, &fds, NULL, NULL, &tv);
-  if (cnt <= 0) {
-    //error or timeout
-    for (int i = 0; i < 2; i++) {
-      if (fd2[i] >= 0) {
-      //既接続のソケットに対して送信
-        char buf[32];
-        cnt = sprintf(buf, "To %d %ld\n", fd2[i], millis());
-        write(fd2[i], buf, cnt);
-      }
-    }
-  }
-  if (FD_ISSET( fd, &fds)) {
-    for (int i = 0; i < 2; i++) {
-      //接続受付
-      if (fd2[i] == -1) {
-        socklen_t len = sizeof(struct sockaddr_in);
-        if ((fd2[i] = accept(fd, (struct sockaddr *)&from_addr, &len)) < 0) {
-          Serial.println("accept error.");
-          while (1);
-        }
-        Serial.println("connect " + String( fd2[i]));
-        break;
-      }
-    }
-  }
-  for (int i = 0; i < 2; i++) {
-    if (fd2[i] != -1 && FD_ISSET(fd2[i], &fds) ) {
-      //受信&接続断検出
-      char buf[256];
-      int rcvCnt = recv(fd2[i], buf, sizeof(buf), 0);
-      Serial.println("rcvd:" + String(buf));
-      if (rcvCnt < 0) {
-        Serial.println("disconnect " + String(fd2[i]));
-        close(fd2[i]);
-        fd2[i] = -1;
-      }
-    }
-  }
-}
-```