交通灯信息系统

代码

• Arduino 发射器代码
• Arduino 接收器和 MySQLdb
• MySQL_UpdateTrafficLData.php
• MySQL_UpdateDistance.php
• EchoJSON
• MainActivity.java
• AndroidManifest.xml
• strings.xml
• activity_main.xml

Arduino 发射器代码Arduino

/* IOTOPIA - 2016-2017 - 交通灯信息系统（发射器）* by Pieter Luyten &Joppe Smeets * * 通过 RF 433MHz 模块将距离发送到另一个 arduino * * RF 433MHz 模块：* tx_pin --> 引脚 3 * * HC-SR04 模块：* trig_pin --> pin 5 * echo_pin --> pin 6 * */#define tx_pin 3#define trig_pin 5#define echo_pin 6#include  // RF 433 MHz 模块库#include "HCSR04.h" // HC-SR04 模块库HCSR04 超声波(trig_pin,echo_pin); int distance;char CharMsg[21];void setup() { Serial.begin(9600); vw_setup(2000); // 每秒比特数 vw_set_tx_pin(tx_pin);}void loop() { distance =Ultrasonic.Ranging(CM); // 以厘米为单位测量距离 while(distance <0){ // 避免错误读数，再次测量距离 distance =Ultrasound.Ranging(CM); } sprintf(CharMsg, "%d,", 距离); vw_send((uint8_t *)CharMsg, strlen(CharMsg)); // 发送距离 vw_wait_tx(); // 等到整个消息消失 Serial.print("Distance (cm):"); Serial.println(距离);延迟（250）；}

Arduino 接收器和 MySQLdbArduino

/* IOTOPIA - 2016-2017 - 交通灯信息系统（接收器 + 上传到 MySQLdb）* by Pieter Luyten &Joppe Smeets * * 通过 RF 从另一个 arduino 接收距离 * 将交通灯数据和距离上传到 MySQL 数据库 * * RF 433MHz 模块：* rx_pin --> 引脚 3 * * 交通灯（3 个 LED）：* RedLED --> 引脚 5 * OrangeLED --> 引脚 6 * GreenLED --> 引脚 7 * * DS3231（实时时钟） :* SCL --> SCL（Arduino Yun 的引脚 3）* SDA --> SDA（Arduino Yun 的引脚 2）* * SD 卡 - Arduino Yun * SD 卡（带 PHP 文件）--> 集成 SD 插槽* /#define RedLED 5#define OrangeLED 6#define GreenLED 7#define rx_pin 9#include  // RF 433 MHz 模块#include  // Alarms#include  // I2C通信#include "RTClib.h" // 实时时钟#include  // 在AR9331 上运行Linux 进程// UnixTime：时间，定义为自1970 年1 月1 日以来经过的秒数long UnixTime_green_1; // 下一个绿灯（在 UnixTime 中）long UnixTime_red_1; // 下一个红灯（在 UnixTime 中）long UnixTime_green_2; // 下一个绿灯（在 UnixTime 中）long UnixTime_red_2; // 下一个红灯（在 UnixTime 中）long s_till_orange; // 秒到 orangeRTC_DS3231 rtc;char StringReceived[22];boolean i;int interval =5; // 以秒为单位的距离； // 在 cmvoid setup() { rtc.begin(); //rtc.adjust(DateTime(F(__DATE__), F(__TIME__))); Serial.begin(9600); Bridge.begin(); // 初始化桥 vw_setup(2000); // 每秒位数 vw_set_rx_pin(rx_pin); vw_rx_start(); Alarm.timerRepeat(interval, UpdateTrafficLData); // 更新交通灯数据（下一个绿灯/红灯...） Alarm.timerRepeat(1,PrintCurrentTime); // 每 x 秒打印一次当前时间 pinMode(GreenLED, OUTPUT); pinMode（橙色LED，输出）； pinMode（红色LED，输出）；数字写入（绿色LED，低）；数字写入（橙色LED，低）；数字写入（红色LED，低）； Serial.println("设置完成");}void loop() { Alarm.delay(0); // 应使用此延迟而不是正常的 Arduino delay()，// 用于及时处理警报和计时器。您可以传递 0 以获得最小延迟。 RF_Listen(); }void RF_Listen(){ uint8_t buf[VW_MAX_MESSAGE_LEN]; uint8_t buflen =VW_MAX_MESSAGE_LEN; if (vw_get_message(buf, &buflen)) { int a; for (a =0; a  0) { char c =p.read(); Serial.print(c); } // 确保发送最后一位数据。 Serial.flush();}void MySQL_UpdateDistance(){ 进程 p; p.begin("/mnt/sda1/MySQL_UpdateDistance.php"); p.addParameter(String(distance)); p.run(); // 读取反馈（用于调试） while (p.available()> 0) { char c =p.read(); Serial.print(c); } // 确保发送最后一位数据。 Serial.flush();}void PrintCurrentTime() { DateTime now =rtc.now(); SetLEDsTrafficL(); Serial.print(now.hour(), DEC); Serial.print(':'); Serial.print(now.minute(), DEC); Serial.print(':'); Serial.print(now.second(), DEC); Serial.print(" "); Serial.println(now.unixtime());}void SetLEDsTrafficL() { DateTime now =rtc.now(); s_till_orange =UnixTime_red_1 - now.unixtime(); if (i ==0) { digitalWrite(GreenLED, LOW);数字写入（橙色LED，低）；数字写入（红色LED，高）； } if (i ==1 &&s_till_orange <=3) { digitalWrite(GreenLED, LOW);数字写入（橙色LED，高）；数字写入（红色LED，低）； } if (i ==1 &&s_till_orange> 3) { digitalWrite(GreenLED, HIGH);数字写入（橙色LED，低）；数字写入（红色LED，低）； }}

MySQL_UpdateTrafficLData.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('数据库连接失败：' . $conn->connect_error, E_USER_ERROR);} $sql="UPDATE TrafficL_data SET UnixTime_green_1='$UnixTime_green_1', UnixTime_red_1='$UnixTime_red_1',UnixTime_green_2='$UnixTime_green_2', UnixTime_red_2='$UnixTime_red_2' WHERE id=1";if($conn->query($sql) ) ===false) { trigger_error('错误的 SQL:' . $sql . ' 错误:' . $conn->error, E_USER_ERROR);}else{echo "数据插入！\n";} ?>

MySQL_UpdateDistance.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('数据库连接失败：' . $conn->connect_error, E_USER_ERROR );}$sql="UPDATE TrafficL_data SET Distance='$Distance'WHERE id=1";if($conn->query($sql) ===false) { trigger_error('Wrong SQL:' . $sql . ' 错误：' . $conn->error, E_USER_ERROR);}else{echo "距离插入！\n";}?>

EchoJSONPHP

MainActivity.javaJava

package com.example.xxx.xxx;//改xxx xxximport android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.util.Log;import android.widget.TextView;import com .android.volley.RequestQueue;import com.android.volley.Response;import com.android.volley.VolleyError;import com.android.volley.toolbox.JsonArrayRequest;import com.android.volley.toolbox.Volley;import org. json.JSONArray;import org.json.JSONException;import org.json.JSONObject;//import java.text.DateFormat;import java.util.Date;import java.util.Timer;//import java.util.TimerTask; import java.util.concurrent.Executors;import java.util.concurrent.Future;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.TimeUnit;public class MainActivity extends AppCompatActivity { // 将显示字符串“data " 保存结果 TextView 结果； //保存推荐速度的textview TextView recSpeed; // 要解析的对象的 URL String JsonURL ="YourURLhere"; // 这个字符串将保存结果 String data =""; // 定义并发处理URL请求的Volley请求队列 RequestQueue requestQueue; //定时器对象每秒更新一次数据 //Timer timer; //speedLimit(cm/s) private final static double maxSpeed =18; //推荐速度私人双速； //表中的次数 public final static int NUMBER_OF_ENTRIES =2; //带绿色时间的数组 long[] unixTimesGreen =new long[NUMBER_OF_ENTRIES]; //数组为红色 long[] unixTimesRed =new long[NUMBER_OF_ENTRIES]; //保存距离私有双距离的变量； //重复updateTable的变量 private final ScheduledExecutorService scheduler =Executors.newSingleThreadScheduledExecutor(); // 用于测试：私有 FuturetimingTask;公共无效滴答（长毫秒）{timingTask =scheduler.scheduleAtFixedRate(new Runnable() { public void run() { updateTable(); } }, 0, 毫秒, TimeUnit.MILLISECONDS); } @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //textViews 将结果转换为 results =(TextView) findViewById(R.id.jsonData); recSpeed =(TextView) findViewById(R.id.recommendedSpeed); //初始化表updateTable(); //每100毫秒更新一次应用程序tick(500); //用于使用定时器对象重复更新 /** timer =new Timer("Timer"); timer.schedule(new UpdateTable(),(long)100,(long)100); */ } //用于使用定时器对象重复更新 /** 私有类 UpdateTable extends TimerTask{ public void run(){ updateTable(); } } */ private void updateTable(){ //重置字符串数据 =""; // 创建 Volley 请求队列 requestQueue =Volley.newRequestQueue(this); // 用于测试 /** // 将结果投射到主布局 XML 中找到的 TextView 中，id 为 jsonData results =(TextView) findViewById(R.id.jsonData); */ // 创建名为arrayreq 的JsonArrayRequest 类，传递需要的参数 //JsonURL 是要从JsonArrayRequest 中获取的URL arrayreq =new JsonArrayRequest(JsonURL, // 第二个参数Listener 覆盖方法onResponse() 并传递 //JSONArray作为参数 new Response.Listener() { // 从 JSON 请求中获取响应 @Override public void onResponse(JSONArray response) { try { // 检索外部数组中的第一个 JSON 对象 JSONObject TrafficLObj =response.getJSONObject( 0); // 从 JSON 对象中检索“trafficArry” JSONArray trafficArry =TrafficLObj.getJSONArray("TrafficLArray"); // 遍历 JSON 数组获取对象并将它们添加到列表视图中，直到没有更多对象TrafficArry for (int i =0; i  maxSpeed) speed =maxSpeed; else speed =distance/((unixTimesGreen[interval]-time));速度=速度*5； }}

AndroidManifest.xmlXML

//更改xxx xxx         

strings.xmlXML

 NooitRood

activity_main.xmlXML

示意图