|
|
| Line 25: |
Line 25: |
| | We need to install python serial first before we can use serial from pcDuino3B by doing: | | We need to install python serial first before we can use serial from pcDuino3B by doing: |
| | | | |
| − | ?
| + | [[File:Code.jpg| 600px]] |
| − | 1
| |
| − | $sudo apt-get install python-serial
| |
| − | (1) test code of python-mqtt:
| |
| | | | |
| − | ?
| + | [[File:Code 1.jpg| 600px]] |
| − | 1
| |
| − | 2
| |
| − | 3
| |
| − | 4
| |
| − | 5
| |
| − | 6
| |
| − | 7
| |
| − | 8
| |
| − | 9
| |
| − | 10
| |
| − | 11
| |
| − | 12
| |
| − | 13
| |
| − | 14
| |
| − | 15
| |
| − | 16
| |
| − | 17
| |
| − | 18
| |
| − | 19
| |
| − | 20
| |
| − | 21
| |
| − | 22
| |
| − | 23
| |
| − | 24
| |
| − | 25
| |
| − | 26
| |
| − | 27
| |
| − | 28
| |
| − | 29
| |
| − | 30
| |
| − | 31
| |
| − | 32
| |
| − | 33
| |
| − | 34
| |
| − | 35
| |
| − | 36
| |
| − | 37
| |
| − | 38
| |
| − | 39
| |
| − | 40
| |
| − | 41
| |
| − | 42
| |
| − | 43
| |
| − | 44
| |
| − | 45
| |
| − | 46
| |
| − | 47
| |
| − | 48
| |
| − | 49
| |
| − | 50
| |
| − | 51
| |
| − | 52
| |
| − | 53
| |
| − | 54
| |
| − | 55
| |
| − | 56
| |
| − | 57
| |
| − | 58
| |
| − | 59
| |
| − | 60
| |
| − | 61
| |
| − | 62
| |
| − | 63
| |
| − | 64
| |
| − | 65
| |
| − | 66
| |
| − | 67
| |
| − | 68
| |
| − | 69
| |
| − | 70
| |
| − | 71
| |
| − | 72
| |
| − | 73
| |
| − | 74
| |
| − | 75
| |
| − | 76
| |
| − | 77
| |
| − | 78
| |
| − | 79
| |
| − | 80
| |
| − | 81
| |
| − | 82
| |
| − | 83
| |
| − | 84
| |
| − | 85
| |
| − | 86
| |
| − | 87
| |
| − | 88
| |
| − | 89
| |
| − | 90
| |
| − | 91
| |
| − | 92
| |
| − | 93
| |
| − | 94
| |
| − | import socket
| |
| − | import sys
| |
| − | import paho.mqtt.publish as publish
| |
| − | import paho.mqtt.client as mqtt
| |
| − |
| |
| − | import serial
| |
| − | myport=serial.Serial('/dev/ttyS1',9600,timeout=1)
| |
| − |
| |
| − | myport.write('test')
| |
| − |
| |
| − | ###
| |
| − |
| |
| − | client_connect=0
| |
| − |
| |
| − | ##
| |
| − | def on_connect(mqttc, obj, flags, rc):
| |
| − | print("rc: "+str(rc))
| |
| − | def on_message(mqttc, obj, msg):
| |
| − | if client_connect==1:
| |
| − | myport.write('S')
| |
| − | print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
| |
| − | connection.send(msg.topic+" "+str(msg.payload))
| |
| − | def on_publish(mqttc, obj, mid):
| |
| − | print("mid: "+str(mid))
| |
| − | def on_subscribe(mqttc, obj, mid, granted_qos):
| |
| − | print("Subscribed: "+str(mid)+" "+str(granted_qos))
| |
| − | def on_log(mqttc, obj, level, string):
| |
| − | print(string)
| |
| − |
| |
| − | #### The following for TCP/IP from Arduino-style part #############
| |
| − | # Create a TCP/IP socket
| |
| − | sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
| |
| − | sock.setsockopt( socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
| |
| − |
| |
| − | # Bind the socket to the port
| |
| − | #server_address = ('localhost', 10000)
| |
| − | server_address = ("192.168.1.134", 10000)
| |
| − | print >>sys.stderr, 'starting up on %s port %s' % server_address
| |
| − |
| |
| − | sock.bind(server_address)
| |
| − |
| |
| − | # Listen for incoming connections
| |
| − | sock.listen(1)
| |
| − |
| |
| − | ################ The following for subscribing to MQTT ##############
| |
| − | mqttc = mqtt.Client()
| |
| − | mqttc.on_message = on_message
| |
| − | mqttc.on_connect = on_connect
| |
| − | mqttc.on_publish = on_publish
| |
| − | mqttc.on_subscribe = on_subscribe
| |
| − |
| |
| − | mqttc.connect("localhost", 1883, 60)
| |
| − |
| |
| − | ### Subscribe to topic '4033', which is the ID of the relay of garage
| |
| − | mqttc.subscribe("4033", 0)
| |
| − | mqttc.loop_start()
| |
| − |
| |
| − | while True:
| |
| − |
| |
| − | # Wait for a connection
| |
| − | print >>sys.stderr, 'waiting for a connection'
| |
| − | connection, client_address = sock.accept()
| |
| − | client_connect=1
| |
| − |
| |
| − | try:
| |
| − | print >>sys.stderr, 'connection from', client_address
| |
| − |
| |
| − | # Receive the data in small chunks and retransmit it
| |
| − | while True:
| |
| − | # debug
| |
| − | #connection.send('Hello world')
| |
| − | ble_data = myport.readline()
| |
| − | if len(ble_data)>0:
| |
| − | print(ble_data)
| |
| − | #data = connection.recv(3)
| |
| − | #print(data)
| |
| − | #if len(data)==0:
| |
| − | #connection.close()
| |
| − | #break
| |
| − |
| |
| − | if "test" in ble_data :
| |
| − | print('okay')
| |
| − |
| |
| − | if "321" in ble_data:
| |
| − | print >>sys.stderr, 'publish 0'
| |
| − | publish.single("3032", "0",hostname="localhost")
| |
| − | if "123" in ble_data:
| |
| − | print >>sys.stderr, 'publish 1'
| |
| − | publish.single("3032", "1",hostname="localhost")
| |
| − |
| |
| − | except KeyboardInterrupt:
| |
| − | # Clean up the connection
| |
| − | connection.close()
| |
| − | sys.exit(1)
| |
| − | (2) test code of Socket:
| |
| | | | |
| − | ?
| + | [[File:Code 2.jpg| 600px]] |
| − | 1
| |
| − | 2 | |
| − | 3
| |
| − | 4
| |
| − | 5
| |
| − | 6
| |
| − | 7
| |
| − | 8
| |
| − | 9
| |
| − | 10
| |
| − | 11
| |
| − | 12
| |
| − | 13
| |
| − | 14
| |
| − | 15
| |
| − | 16
| |
| − | 17
| |
| − | 18
| |
| − | 19
| |
| − | 20
| |
| − | 21
| |
| − | 22
| |
| − | 23
| |
| − | 24
| |
| − | 25
| |
| − | 26
| |
| − | 27
| |
| − | 28
| |
| − | 29
| |
| − | 30
| |
| − | 31
| |
| − | 32
| |
| − | 33
| |
| − | 34
| |
| − | 35
| |
| − | 36
| |
| − | 37
| |
| − | #include "core.h"
| |
| − | #include "stdio.h"
| |
| − | #include "stdlib.h"
| |
| − | #include "string.h"
| |
| − | #include <sys/socket.h>
| |
| − | #include <netinet/in.h>
| |
| − | #include <arpa/inet.h>
| |
| − |
| |
| − | int sockfd,n, flags;
| |
| − | socklen_t addr_len;
| |
| − | struct sockaddr_in servaddr,cliaddr;
| |
| − | char sendline[1000];
| |
| − | char recvline[1000];
| |
| − | int rc;
| |
| − |
| |
| − | void setup()
| |
| − | {
| |
| − | sockfd=socket(AF_INET,SOCK_STREAM,0);
| |
| − | bzero(&servaddr,sizeof(servaddr));
| |
| − | servaddr.sin_family = AF_INET;
| |
| − | servaddr.sin_addr.s_addr=inet_addr("192.168.1.134");
| |
| − | servaddr.sin_port=htons(10000);
| |
| − | Serial.begin(9600);
| |
| − | if((rc = connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)))<0)
| |
| − | {
| |
| − | perror("Client-connect () error");
| |
| − | exit(-1);
| |
| − | }
| |
| − |
| |
| − | flags=fcntl(sockfd,F_GETFL);
| |
| − | flags|=O_NONBLOCK;
| |
| − | fcntl(sockfd,F_SETFL,flags);
| |
| − | }
| |
| − | void loop()
| |
| − | {
| |
| − |
| |
| − | }
| |
| − | (3) test code of Arduino
| |
| | | | |
| − | ?
| + | [[File:Code 3.jpg| 600px]] |
| − | 1
| + | |
| − | 2
| + | [[File:Code 4.jpg| 600px]] |
| − | 3 | |
| − | 4
| |
| − | 5
| |
| − | 6
| |
| − | 7
| |
| − | 8
| |
| − | 9
| |
| − | 10
| |
| − | 11
| |
| − | 12
| |
| − | 13
| |
| − | 14
| |
| − | 15
| |
| − | 16
| |
| − | 17
| |
| − | 18
| |
| − | 19
| |
| − | 20
| |
| − | 21
| |
| − | 22
| |
| − | 23
| |
| − | 24
| |
| − | 25
| |
| − | 26
| |
| − | 27
| |
| − | 28
| |
| − | 29
| |
| − | 30
| |
| − | 31
| |
| − | 32
| |
| − | 33
| |
| − | 34
| |
| − | 35
| |
| − | 36
| |
| − | 37
| |
| − | 38
| |
| − | 39
| |
| − | 40
| |
| − | 41
| |
| − | 42
| |
| − | 43
| |
| − | 44
| |
| − | 45
| |
| − | 46
| |
| − | 47
| |
| − | 48
| |
| − | #include <SoftwareSerial.h>
| |
| − |
| |
| − | #define RxD 11
| |
| − | #define TxD 12
| |
| − | SoftwareSerial mySerial(RxD,TxD);
| |
| − |
| |
| − | char dat;
| |
| − | int i,flag=1;
| |
| − | void setup()
| |
| − | {
| |
| − | pinMode(RxD, INPUT);
| |
| − | pinMode(TxD, OUTPUT);
| |
| − | pinMode(13,OUTPUT);
| |
| − | pinMode(8,INPUT);
| |
| − | digitalWrite(8,HIGH);
| |
| − | mySerial.begin(9600); // the ble4.0 baud rate
| |
| − | Serial.begin(9600); // the terminal baud rate
| |
| − | }
| |
| − |
| |
| − | void loop()
| |
| − | {
| |
| − | if(Serial.available())
| |
| − | {
| |
| − | mySerial.print((char)Serial.read());
| |
| − | }
| |
| − |
| |
| − | if(mySerial.available())
| |
| − | {
| |
| − | dat = char(mySerial.read());
| |
| − | Serial.print(dat);
| |
| − | if(dat == 'S') i++;
| |
| − | if(i%2) digitalWrite(13,LOW);
| |
| − | else digitalWrite(13,HIGH);
| |
| − | }
| |
| − |
| |
| − | if( (digitalRead(8)==1)&&(flag==1))
| |
| − | {
| |
| − | flag = 0 ;
| |
| − | mySerial.write("123\r\n");
| |
| − | Serial.write("123\r\n");
| |
| − | }
| |
| − | if( (digitalRead(8)==0)&&(flag==0))
| |
| − | {
| |
| − | flag =1 ;
| |
| − | mySerial.write("321\r\n");
| |
| − | Serial.write("321\r\n");
| |
| − | }
| |
| − | }
| |
Introduction
Before this article, there is post about DIY Smart home connecting through Wifi. Nowadays, the wearable devices such as smartbands and smart watch are extremely popular. So it’s time to talk about Bluetooth4.0, this article is all about how to DIY your own smart home using BLE4.0 Shield and BLE4.0 Bee as connection devices, pcduino as openhab server, Arduino as device.
Usage
Install openHAB
Install openHAB server software on pcDuino, get more detail form linksprite learn center:
http://learn.linksprite.com/?s=openhab
or, download the image file below, then update ( install openh under “/opt/openhab” folder):
http://pan.baidu.com/s/1ntHtCyX?qq-pf-to=pcqq.c2c code: fh6c
For more detail about how to use BLE4.0 shield ( the usage of BLE4.0 Bee is the same as BLE4.0 Shield )
http://learn.linksprite.com/arduino/shields/how-to-use-ble4-0-shield/
Test Code
We need to install python serial first before we can use serial from pcDuino3B by doing:
