Финал: доступ к сайту
Мы разобрали, как настроить подключение к Wi-Fi с помощью Embassy. Поскольку предыдущая глава получилась довольно длинной, мы не стали подробно разбирать функцию access_website. В этой главе сосредоточимся на том, как отправить HTTP-запрос и получить ответ от сайта с помощью крейта reqwless, а затем наконец запустим код.
Отправка HTTP-запроса
Начнём с инициализации DNS-сокета и TCP-клиента.
Конфигурация TLS:
Далее настраиваем конфигурацию TLS, используя tls_seed — случайное число, которое мы сгенерировали ранее и передали в функцию. Мы настраиваем TLS так, чтобы пропустить проверку SSL-сертификата, установив TlsVerify::None. Это не рекомендуется для рабочих окружений, но для простоты мы используем такую небезопасную настройку. В рабочем окружении нужно настроить TLS с проверкой сертификатов и передать цепочку сертификатов, чтобы её можно было использовать для проверки.
Остальное достаточно просто. Мы инициализируем HTTP-клиент с TCP-клиентом, DNS-сокетом и конфигурацией TLS. Затем отправляем GET-запрос на сайт jsonplaceholder, который возвращает содержимое в формате JSON. Мы читаем содержимое и выводим его в консоль.
#![allow(unused)]
fn main() {
async fn access_website(stack: Stack<'_>, tls_seed: u64) {
let mut rx_buffer = [0; 4096];
let mut tx_buffer = [0; 4096];
let dns = DnsSocket::new(stack);
let tcp_state = TcpClientState::<1, 4096, 4096>::new();
let tcp = TcpClient::new(stack, &tcp_state);
let tls = TlsConfig::new(
tls_seed,
&mut rx_buffer,
&mut tx_buffer,
reqwless::client::TlsVerify::None,
);
let mut client = HttpClient::new_with_tls(&tcp, &dns, tls);
let mut buffer = [0u8; 4096];
let mut http_req = client
.request(
reqwless::request::Method::GET,
"https://jsonplaceholder.typicode.com/posts/1",
)
.await
.unwrap();
let response = http_req.send(&mut buffer).await.unwrap();
info!("Got response");
let res = response.body().read_to_end().await.unwrap();
let content = core::str::from_utf8(res).unwrap();
println!("{}", content);
}
}Клонирование существующего проекта
Вы также можете клонировать (или посмотреть) созданный мной проект и перейти в папку wifi-async-http.
git clone https://github.com/ImplFerris/esp32-projects
cd esp32-projects/wifi-async-http
Как запустить?
Обычно мы просто запускаем cargo run --release, но на этот раз нужно также передать переменные окружения для подключения к Wi-Fi.
SSID=YOUR_WIFI_NAME PASSWORD=YOUR_WIFI_PASSWORD cargo run --release
Полный код
#![no_std]
#![no_main]
#![deny(
clippy::mem_forget,
reason = "mem::forget is generally not safe to do with esp_hal types, especially those \
holding buffers for the duration of a data transfer."
)]
use defmt::info;
use embassy_executor::Spawner;
use embassy_net::{
DhcpConfig, Runner, Stack, StackResources,
dns::DnsSocket,
tcp::client::{TcpClient, TcpClientState},
};
use embassy_time::{Duration, Timer};
use esp_hal::clock::CpuClock;
use esp_hal::rng::Rng;
use esp_hal::timer::timg::TimerGroup;
use esp_println::{self as _, println};
use esp_radio::wifi::{
ClientConfig, ModeConfig, ScanConfig, WifiController, WifiDevice, WifiEvent, WifiStaState,
};
use reqwless::client::{HttpClient, TlsConfig};
#[panic_handler]
fn panic(_: &core::panic::PanicInfo) -> ! {
loop {}
}
extern crate alloc;
// Создаёт дескриптор приложения по умолчанию, который требуется загрузчику esp-idf.
// Подробнее см.: <https://docs.espressif.com/projects/esp-idf/en/stable/esp32/api-reference/system/app_image_format.html#application-description>
esp_bootloader_esp_idf::esp_app_desc!();
// Если устраивает nightly-компилятор, можно использовать макрос из крейта static_cell: https://docs.rs/static_cell/2.1.0/static_cell/macro.make_static.html
macro_rules! mk_static {
($t:ty,$val:expr) => {{
static STATIC_CELL: static_cell::StaticCell<$t> = static_cell::StaticCell::new();
#[deny(unused_attributes)]
let x = STATIC_CELL.uninit().write(($val));
x
}};
}
const SSID: &str = env!("SSID");
const PASSWORD: &str = env!("PASSWORD");
#[esp_rtos::main]
async fn main(spawner: Spawner) -> ! {
// generator version: 1.0.0
let config = esp_hal::Config::default().with_cpu_clock(CpuClock::max());
let peripherals = esp_hal::init(config);
esp_alloc::heap_allocator!(#[unsafe(link_section = ".dram2_uninit")] size: 98767);
let timg0 = TimerGroup::new(peripherals.TIMG0);
esp_rtos::start(timg0.timer0);
info!("Embassy initialized!");
// let radio_init = esp_radio::init().expect("Failed to initialize Wi-Fi/BLE controller");
let rng = Rng::new();
let radio_init = &*mk_static!(
esp_radio::Controller<'static>,
esp_radio::init().expect("Failed to initialize Wi-Fi/BLE controller")
);
let (wifi_controller, interfaces) =
esp_radio::wifi::new(&radio_init, peripherals.WIFI, Default::default())
.expect("Failed to initialize Wi-Fi controller");
let wifi_interface = interfaces.sta;
let net_seed = rng.random() as u64 | ((rng.random() as u64) << 32);
let tls_seed = rng.random() as u64 | ((rng.random() as u64) << 32);
let dhcp_config = DhcpConfig::default();
let config = embassy_net::Config::dhcpv4(dhcp_config);
// Инициализируем сетевой стек
let (stack, runner) = embassy_net::new(
wifi_interface,
config,
mk_static!(StackResources<3>, StackResources::<3>::new()),
net_seed,
);
spawner.spawn(connection(wifi_controller)).ok();
spawner.spawn(net_task(runner)).ok();
wait_for_connection(stack).await;
access_website(stack, tls_seed).await;
loop {}
}
async fn wait_for_connection(stack: Stack<'_>) {
println!("Waiting for link to be up");
loop {
if stack.is_link_up() {
break;
}
Timer::after(Duration::from_millis(500)).await;
}
println!("Waiting to get IP address...");
loop {
if let Some(config) = stack.config_v4() {
println!("Got IP: {}", config.address);
break;
}
Timer::after(Duration::from_millis(500)).await;
}
}
#[embassy_executor::task]
async fn connection(mut controller: WifiController<'static>) {
println!("start connection task");
println!("Device capabilities: {:?}", controller.capabilities());
loop {
match esp_radio::wifi::sta_state() {
WifiStaState::Connected => {
// ждём, пока соединение не будет разорвано
controller.wait_for_event(WifiEvent::StaDisconnected).await;
Timer::after(Duration::from_millis(5000)).await
}
_ => {}
}
if !matches!(controller.is_started(), Ok(true)) {
let client_config = ModeConfig::Client(
ClientConfig::default()
.with_ssid(SSID.into())
.with_password(PASSWORD.into()),
);
controller.set_config(&client_config).unwrap();
println!("Starting wifi");
controller.start_async().await.unwrap();
println!("Wifi started!");
println!("Scan");
let scan_config = ScanConfig::default().with_max(10);
let result = controller
.scan_with_config_async(scan_config)
.await
.unwrap();
for ap in result {
println!("{:?}", ap);
}
}
println!("About to connect...");
match controller.connect_async().await {
Ok(_) => println!("Wifi connected!"),
Err(e) => {
println!("Failed to connect to wifi: {:?}", e);
Timer::after(Duration::from_millis(5000)).await
}
}
}
}
#[embassy_executor::task]
async fn net_task(mut runner: Runner<'static, WifiDevice<'static>>) {
runner.run().await
}
async fn access_website(stack: Stack<'_>, tls_seed: u64) {
let mut rx_buffer = [0; 4096];
let mut tx_buffer = [0; 4096];
let dns = DnsSocket::new(stack);
let tcp_state = TcpClientState::<1, 4096, 4096>::new();
let tcp = TcpClient::new(stack, &tcp_state);
let tls = TlsConfig::new(
tls_seed,
&mut rx_buffer,
&mut tx_buffer,
reqwless::client::TlsVerify::None,
);
let mut client = HttpClient::new_with_tls(&tcp, &dns, tls);
let mut buffer = [0u8; 4096];
let mut http_req = client
.request(
reqwless::request::Method::GET,
"https://jsonplaceholder.typicode.com/posts/1",
)
.await
.unwrap();
let response = http_req.send(&mut buffer).await.unwrap();
info!("Got response");
let res = response.body().read_to_end().await.unwrap();
let content = core::str::from_utf8(res).unwrap();
println!("{}", content);
}