123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149 |
- #define USE_SERIAL Serial
- #include <Arduino.h>
- #include <Hash.h>
- #include <ESP8266WiFi.h>
- #include <WebSocketsClient.h>
- const char* wlan_ssid = "yourssid";
- const char* wlan_password = "somepassword";
- const char* ws_host = "the.host.net";
- const int ws_port = 80;
- const char* stompUrl = "/socketentry/websocket";
- WebSocketsClient webSocket;
- void sendMessage(String & msg) {
- webSocket.sendTXT(msg.c_str(), msg.length() + 1);
- }
- void webSocketEvent(WStype_t type, uint8_t * payload, size_t length) {
- switch (type) {
- case WStype_DISCONNECTED:
- USE_SERIAL.printf("[WSc] Disconnected!\n");
- break;
- case WStype_CONNECTED:
- {
- USE_SERIAL.printf("[WSc] Connected to url: %s\n", payload);
-
- String msg = "CONNECT\r\naccept-version:1.1,1.0\r\nheart-beat:10000,10000\r\n\r\n";
- sendMessage(msg);
- }
- break;
- case WStype_TEXT:
- {
-
-
-
- String text = (char*) payload;
- USE_SERIAL.printf("[WSc] get text: %s\n", payload);
- if (text.startsWith("CONNECTED")) {
-
- String msg = "SUBSCRIBE\nid:sub-0\ndestination:/user/queue/messages\n\n";
- sendMessage(msg);
- delay(1000);
-
- msg = "SEND\ndestination:/app/message\n\n{\"user\":\"esp\",\"message\":\"Hello!\"}";
- sendMessage(msg);
- delay(1000);
-
- } else {
-
-
- }
- break;
- }
- case WStype_BIN:
- USE_SERIAL.printf("[WSc] get binary length: %u\n", length);
- hexdump(payload, length);
-
-
- break;
- }
- }
- void setup() {
-
-
- USE_SERIAL.begin(115200);
-
- USE_SERIAL.println();
-
- USE_SERIAL.print("Logging into WLAN: "); Serial.print(wlan_ssid); Serial.print(" ...");
- WiFi.mode(WIFI_STA);
- WiFi.begin(wlan_ssid, wlan_password);
- while (WiFi.status() != WL_CONNECTED) {
- delay(500);
- USE_SERIAL.print(".");
- }
- USE_SERIAL.println(" success.");
- USE_SERIAL.print("IP: "); USE_SERIAL.println(WiFi.localIP());
-
- webSocket.begin(ws_host, ws_port, stompUrl);
- webSocket.setExtraHeaders();
-
- webSocket.onEvent(webSocketEvent);
- }
- void loop() {
- webSocket.loop();
- }
|