WeMosを使ってみる

RaspberryとのSocket通信(WeMos→Raspberry)


最初に、Raspberry側がサーバー、WeMos側がクライアントのSocket通信を紹介します。

【Raspberry側】

以下のコード(server.c)をコンパイルして実行します。
クライアントから受信した大文字を小文字に、小文字を大文字に変換して送り返す単純なものです。
コンパイルは単純に「cc -o server server.c」で、実行は「sudo ./server」です。

#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <time.h>
#include <limits.h>

#define PORT 9876 //クライアントプログラムとポート番号を合わせてください

int main(int argc, char **argv){
  int i;
  int srcSocket; //自分
  int dstSocket; //相手
  // sockaddr_in 構造体
  struct sockaddr_in srcAddr;
  struct sockaddr_in dstAddr;
  socklen_t dstAddrSize;
  // 各種パラメータ
  int numrcv;
  char buf[1024];
  int loopMax;
  int loopCnt;

  time_t start_time=0, end_time;
  double dtime;

  loopMax=INT_MAX;
  if (argc == 2) {
    loopMax=atoi(argv[1]);
  }

  // sockaddr_in 構造体のセット
  bzero((char *)&srcAddr, sizeof(srcAddr));
  srcAddr.sin_port = htons(PORT);
  srcAddr.sin_family = AF_INET;
  srcAddr.sin_addr.s_addr = INADDR_ANY;
    
  // ソケットの生成(ストリーム型)
  srcSocket = socket(AF_INET, SOCK_STREAM, 0);
  // ソケットのバインド
  bind(srcSocket, (struct sockaddr *)&srcAddr, sizeof(srcAddr));
  // 接続の許可
  listen(srcSocket, 5);
 
  for(loopCnt=0;loopCnt<loopMax;loopCnt++) {
//  while(1){
    // 接続の受付け
    printf("接続を待っています\nクライアントプログラムを動かして下さい\n");
    dstAddrSize = sizeof(dstAddr);
    dstSocket = accept(srcSocket, (struct sockaddr *)&dstAddr, &dstAddrSize);
    printf("%s から接続を受けました\n",inet_ntoa(dstAddr.sin_addr));
    if (start_time == 0) time( &start_time );
        
    while(1) { // クライアントがSocketをクローズしてからこちらもクローズする
      //パケットの受信
      memset(buf,0,sizeof(buf));
      numrcv = read(dstSocket, buf, 1024);
      printf("numrcv=%d\n",numrcv);
      if(numrcv ==0 || numrcv ==-1 ){ // client close socket
        close(dstSocket); break;
      }
      printf("Recv=[%s]",buf);
      for (i=0; i< numrcv; i++){ // bufの中の小文字を大文字に変換
        if(isalpha(buf[i])) {
          if(islower(buf[i])) {
            buf[i] = toupper(buf[i]);
          } else {
            buf[i] = tolower(buf[i]);
          }
        }
      }
      // パケットの送信
      write(dstSocket, buf, numrcv);
      printf("->Send=[%s]\n",buf);
    } // end while
  } // end for
  time( &end_time );
  dtime=difftime( end_time, start_time );
  printf("loop=%d difftime=%f[sec] %f[min]\n",loopMax,dtime,dtime/60);
  return(0);
}

プログラムを起動すると以下の表示となります。



【WeMos側】

WeMos側のスケッチは以下の通りです。
相手側(今回はRaspberry)とポート番号(今回は9876番を使用)とIPアドレスを合わせて下さい。
ここが合っていないと正しく通信できません。
赤字の部分は自分の環境に合わせて変更してください。

/*
 *  This sketch sends a message to a TCP server
 *
 */

#include <ESP8266WiFi.h>
#include <ESP8266WiFiMulti.h>

const char* ssid = "アクセスポイントのSSID";
const char* password = "アクセスポイントのパス ワード";

ESP8266WiFiMulti WiFiMulti;

void setup() {
    Serial.begin(9600);

    // We start by connecting to a WiFi network
    WiFiMulti.addAP(ssid, password);

    Serial.println();
    Serial.println();
    Serial.print("Wait for WiFi...");

    while(WiFiMulti.run() != WL_CONNECTED) {
        Serial.print(".");
        delay(500);
    }

    Serial.println("");
    Serial.println("WiFi connected");
    Serial.print("IP address: ");
    Serial.println(WiFi.localIP());

    delay(500);
}


void loop() {
    const uint16_t port = 9876;
    const char * host = "192.168.111.101"; // ip or dns
    static int number=0;
   
   
    Serial.print("connecting to ");
    Serial.println(host);

    // Use WiFiClient class to create TCP connections
    WiFiClient client;

    if (!client.connect(host, port)) {
        Serial.println("connection failed");
        Serial.println("wait 5 sec...");
        delay(5000);
        return;
    }

    // This will send the request to the server
    char smsg[40];
    sprintf(smsg,"data from WeMos %05d",number++);
    client.print(smsg);
   

    //read back one line from server
    String line;
    line = client.readStringUntil('\0');
    Serial.print("[");
    Serial.print(smsg);
    Serial.print("]->[");
    Serial.print(line);
    Serial.println("]");
    Serial.println("closing connection");
    client.stop();
   
    Serial.println("wait 5 sec...");
    delay(5000);
}

このスケッチを実行するとRaspberry側の表示は以下のようになります。




Arduino-IDEのシリアルモニターはこのように表示されます。



しばらく放置しましたが、順調に動いています。



次は、Raspberryがクライアント、WeMosがサーバーのSocket通信を紹介します。

続く....