Kod dla ATmegi:
[syntax=c]/*
* M328_NRF24.c
* Created: 2014-08-10 14:51:16
*/
#include <avr/io.h>
#include <stdint.h>
#include <util/delay.h>
#include <string.h>
#include <avr/interrupt.h>
#include <util/atomic.h>
#include "NRF24.h"
#define ID 0x01
void DHT11(uint8_t dht[])
{
//dht11[0] i dht11[1] to wilgotnosc, dht11[2] i dht11[3] to temperatura w C, dht11[4] to Check-Sum, dht11[5] to sprawdzenie poprawności transmisji
//inicjalizacja
_delay_ms(1000);
DDRD |= (1<<PD7);
PORTD &= ~(1<<PD7);
_delay_ms(18);
PORTD |= (1<<PD7);
_delay_us(10);
DDRD &= ~(1<<PD7);
_delay_us(30);
if(PIND & (1<<PD7))//sprawdzam czy DHT odpowiedział, jak dalej jest 1 to znaczy że nie zadziałał
{
dht[5]=0;//jeżeli mamy w dht[5] zero to znaczy że pojawił sie błąd
}
_delay_us(80);
if(!(PIND & (1<<PD7)))
{
dht[5]=0;
}
_delay_us(80);
//koniec inicjalizacji
for(uint8_t i=0; i<5; i++)
{
uint8_t bajt=0;
for(uint8_t j=0; j<8; j++)
{
while(!(PIND & (1<<PD7)));//ok 50us
_delay_us(35);
if(PIND & (1<<PD7))
{
bajt |= (1<<(7-j));
}
while(PIND & (1<<PD7));
}
dht[i]=bajt;
}
}
int main()
{
DDRC |= 0xFF;
PORTC |= 0;
uint8_t dht11[6]={0,0,0,0,0,0};
//adresy dla RX
//uint8_t RX0_adres[5] = {0x30,0x71,0x12,0xE2,0x30};//dla ATmega
//uint8_t RX1_adres[5] = {0x31,0x71,0x12,0xE2,0x30};
uint8_t RX0_adres[5] = {0xe7,0xe7,0xe7,0xe7,0xe7};//dla RPi
uint8_t RX1_adres[5] = {0xc2,0xc2,0xc2,0xc2,0xc2};
//uint8_t i;
uint8_t data[]={0,0,0,0,0};//dane do wyslania
//Inicjalizacja NRF i SPI
NRF24_init();
//Ustaw adres dla TX
Set_Tx_Adr(RX0_adres);
//Ustaw adres dla RX, wykorzystywana jest rura 1 (P1)
Set_Rx_Adr(RX_ADDR_P1, RX1_adres);
//ustawianie adresu dla rury P2-P5
Set_Px_Adr(RX_ADDR_P2, 0x32);
Set_Px_Adr(RX_ADDR_P3, 0x33);
Set_Px_Adr(RX_ADDR_P4, 0x34);
Set_Px_Adr(RX_ADDR_P5, 0x35);
tryb_RX();//dla odbiornika
//data[0]=0;
uint8_t flaga=0;
while(1)
{
/*DHT11(dht11);
data[0]=(dht11[0]+dht11[1]);
data[1]=(dht11[2]+dht11[3]);
wyslij_dane(data, ((sizeof data)/(sizeof *data)), ACK);//wyslij wszystkie bajty pakietu z potwierdzeniem (NOACK - bez potwierdzenia)
while(jest_wysylane());
data[0]++;
_delay_ms(500);*/
//dla odiornika
//tryb_RX();
//dla lewego ukladu
/*if(dane_gotowe())//czy jest cos do odebrania
{
//i= dlugosc_danych();//ile bajtow jest do odebrania
odbierz_dane(data);//pobierz dane z FIFO
}
if(data[0]==ID)
{
DHT11(dht11);
data[1]=(dht11[0]+dht11[1]);
data[2]=(dht11[2]+dht11[3]);
wyslij_dane(data, ((sizeof data)/(sizeof *data)), ACK);
while(jest_wysylane());
data[0]=0;
tryb_RX();
}*/
//dla prawego ukladu
if(flaga==0)
{
data[0]=0x01;
wyslij_dane(data, ((sizeof data)/(sizeof *data)), ACK);
while(jest_wysylane());
tryb_RX();//dla odbiornika
flaga=1;
}
if(dane_gotowe() && flaga==1)//czekam az dane sie pojawia
{
odbierz_dane(data);//pobierz dane z FIFO
PORTC = data[1];
flaga=0;
}
_delay_ms(500);
}
}[/syntax]
Kod dla Raspberry Pi (Python):
[syntax=python]import RPi.GPIO as GPIO
from lib_nrf24 import NRF24
import time
import spidev
import urllib
import urllib2
GPIO.setmode(GPIO.BCM)
pipes = [[0xE7, 0xE7, 0xE7, 0xE7, 0xE7], [0xC2, 0xC2, 0xC2, 0xC2, 0xC2]]
radio = NRF24(GPIO, spidev.SpiDev())
radio.begin(0,17)
radio.setPayloadSize(32)
radio.setChannel(0x60)
radio.setDataRate(NRF24.BR_250KBPS)
radio.setPALevel(NRF24.PA_MIN)
radio.setAutoAck(True)
radio.enableDynamicPayloads()
radio.enableAckPayload()
#radio.openReadingPipe(1, pipes[1]) #tu mamy otwarcie odczytu
radio.openWritingPipe(pipes[1]) #tu mamy otwarcie wysylania
radio.printDetails()
#radio.startListening() #uruchomienie nasluchu
flaga=0;
while True:
if flaga==0:
radio.openWritingPipe(pipes[1]) #tu mamy otwarcie wysylania
message = [0x01, 0, 0, 0, 0]
radio.write(message)
print("Wyslano: ")
print(message)
radio.openReadingPipe(1, pipes[1]) #tu mamy otwarcie odczytu
radio.startListening() #uruchomienie nasluchu
flaga=1
if flaga==1:
ackPL = [1]
while not radio.available(0):
time.sleep(1/100)
print("Wyslansdfo: ")
receivedMessage = []
radio.read(receivedMessage, radio.getDynamicPayloadSize())
print("Received: {}".format(receivedMessage))
radio.writeAckPayload(1, ackPL, len(ackPL))
url = 'http://192.168.0.16:8080/json.htm?type=command¶m=udevice&idx=5&nvalue=0&svalue='
request = urllib2.Request(url + str(receivedMessage[2]) + ';' + str(receivedMessage[1]) + ';0')
response = urllib2.urlopen(request)
radio.stopListening()#przestaje nasluchiwac
flaga=0
time.sleep(1)
#ackPL = [1]
#while not radio.available(0):
#time.sleep(1/100)
#receivedMessage = []
#radio.read(receivedMessage, radio.getDynamicPayloadSize())
#radio.writeAckPayload(1, ackPL, len(ackPL))
#url = 'http://192.168.0.16:8080/json.htm?type=command¶m=udevice&idx=5&nvalue=0&svalue='
#request = urllib2.Request(url + str(receivedMessage[1]) + ';' + str(receivedMessage[0]) + ';0')
#response = urllib2.urlopen(request)[/syntax]
Ogólnie działanie jest takie: RP wysyła mi w powietrze numer układu który ma mi odpowiedzieć (numer to 0x01), wywołany układ odpowiada i wysyła pomierzone dane. Tyle. Będę bardzo wdzięczny za wskazanie błęduStatystyki: Napisane przez matti0010 — 28 sie 2016, o 20:40
]]>
Widzę że za szybko się cieszyłem, przesył leci nadal, lecz widzę że nie zawsze dobrze. Mimo wszystko to mi wystarcza 
