python通过udp协议获取arduino温湿度信息

zhaopengxslc

1. #include <DHT.h>
   
2. #include <SPI.h>         // needed for Arduino versions later than 0018
   
3. #include <Ethernet.h>
   
4. #include <EthernetUdp.h>         // UDP library from: [email][email protected][/email] 12/30/2008
   
5. 
   
6. #define DHTPIN 2     // what pin we're connected to
   
7. #define DHTTYPE DHT11   // DHT 11
   
8. 
   
9. // Enter a MAC address and IP address for your controller below.
   
10. // The IP address will be dependent on your local network:
    
11. byte mac[] = {  
    
12.   0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED };
    
13. IPAddress ip(192, 168, 2, 177);
    
14. unsigned int localPort = 8000;      // local port to listen on
    
15. 
    
16. // buffers for receiving and sending data
    
17. char packetBuffer[UDP_TX_PACKET_MAX_SIZE]; //buffer to hold incoming packet,
    
18. char  ReplyBuffer[UDP_TX_PACKET_MAX_SIZE];       // a string to send back
    
19. char tempBuf[UDP_TX_PACKET_MAX_SIZE];
    
20. 
    
21. // An EthernetUDP instance to let us send and receive packets over UDP
    
22. EthernetUDP Udp;
    
23. DHT dht(DHTPIN, DHTTYPE);
    
24. 
    
25. void setup() {
    
26.   // start the Ethernet and UDP:
    
27.   Ethernet.begin(mac,ip);
    
28.   Udp.begin(localPort);
    
29.   dht.begin();
    
30.   Serial.begin(9600);
    
31. }
    
32. 
    
33. float getHumidity()
    
34. {
    
35.   float h = dht.readHumidity();
    
36.   if(isnan(h))
    
37.   {
    
38.     return 0;
    
39.   }
    
40.   return h;
    
41. }
    
42. 
    
43. float getTemperature()
    
44. {
    
45.   float t = dht.readTemperature();
    
46.   if(isnan(t))
    
47.   {
    
48.     return 0;
    
49.   }
    
50.   return t;
    
51. }
    
52. 
    
53. void loop() {
    
54.   float h=0.0,t=0.0;
    
55.   //float h = dht.readHumidity();
    
56.   //float t = dht.readTemperature();
    
57. /* if (isnan(t) || isnan(h))
    
58.   {
    
59.     Serial.println("Failed to read from DHT");
    
60.   }
    
61.   else
    
62.   {
    
63.     Serial.print("Humidity: ");
    
64.     Serial.print(h);
    
65.     Serial.print(" %\t");
    
66.     Serial.print("Temperature: ");
    
67.     Serial.print(t);
    
68.     Serial.println(" *C");
    
69.   }*/
    
70.   
    
71.   
    
72.   // if there's data available, read a packet
    
73.   int packetSize = Udp.parsePacket();
    
74.   if(packetSize)
    
75.   {
    
76.     Serial.print("Received packet of size ");
    
77.     Serial.println(packetSize);
    
78.     Serial.print("From ");
    
79.     IPAddress remote = Udp.remoteIP();
    
80.     for (int i =0; i < 4; i++)
    
81.     {
    
82.       Serial.print(remote[i], DEC);
    
83.       if (i < 3)
    
84.       {
    
85.         Serial.print(".");
    
86.       }
    
87.     }
    
88.     Serial.print(", port ");
    
89.     Serial.println(Udp.remotePort());
    
90. 
    
91.     // read the packet into packetBufffer
    
92.     Udp.read(packetBuffer,UDP_TX_PACKET_MAX_SIZE);
    
93.    
    
94.     switch(packetBuffer[0])
    
95.     {
    
96.       case '0':  //control
    
97.         break;
    
98.       case '1':  //informaiton
    
99.         switch(packetBuffer[1])
    
100.         {
     
101.           case '0': //temperature and humility
     
102.             switch(packetBuffer[2])
     
103.             {
     
104.                case '1':
     
105.                  h=getHumidity();
     
106.                  dtostrf(h,10,2,tempBuf);
     
107.                  sprintf(ReplyBuffer,"100humidity:%s",tempBuf);
     
108.                  break;
     
109.               case '0':  //temperature
     
110.                 t=getTemperature();
     
111.                 dtostrf(t,10,2,tempBuf);
     
112.                 sprintf(ReplyBuffer,"100Temperature:%s",tempBuf);
     
113.                 break;
     
114. 
     
115.               /*case :  //humility
     
116.                 float h=getHumidity();
     
117.                 sprintf(ReplyBuffer,"101Humidity:%f\n",h);
     
118.                 break;*/
     
119.             }
     
120.             break;
     
121.            case '1': //air controler
     
122.              break;
     
123.         }
     
124.         break;
     
125.       default:
     
126.         Serial.println("Error");
     
127.     }
     
128.    
     
129.     Serial.println("Contents:");
     
130.     Serial.println(packetBuffer);
     
131.     memset(packetBuffer,'\0',UDP_TX_PACKET_MAX_SIZE);
     
132. 
     
133.     // send a reply, to the IP address and port that sent us the packet we received
     
134.     Serial.println(ReplyBuffer);
     
135.     Udp.beginPacket(Udp.remoteIP(),Udp.remotePort());
     
136.     Udp.write(ReplyBuffer);
     
137.     Udp.endPacket();
     
138.   }
     
139.   delay(10);
     
140. }
     

复制代码

[pre lang="python" line="1"]from socket import *

HOST="192.168.2.177"
PORT=8000
BUFSIZE=1024
ADDR=(HOST,PORT)

udpCliSock=socket(AF_INET,SOCK_DGRAM)
while True:
    data=raw_input(">")
    if not data:
        break
    udpCliSock.sendto(data,ADDR)
    data,ADDR=udpCliSock.recvfrom(BUFSIZE)
    if not data:
        break
    print data,ADDR
udpCliSock.close()
[/code]

说明
输入100获取温度值
输入101获取湿度值

topdog

很新颖，眼前一亮。