Simple networking sockets

The wasmedge_wasi_socket crate enables Rust developers to create networking applications and compile them into WebAssembly for WasmEdge Runtime. One of the key features of WasmEdge is that it supports non-blocking sockets. That allows even a single threaded WASM application to handle concurrent network requests. For example, while the program is waiting for data to stream in from one connection, it can start or handle another connection.

In this chapter, we will start with simple HTTP client and server examples. Then in the next chapter, we will cover the more complex non-blocking examples.

An HTTP client example

The source code for the HTTP client is available as follows.

  1. use wasmedge_http_req::request;
  3. fn main() {
  4.   let mut writer = Vec::new(); //container for body of a response
  5.   let res = request::get("http://127.0.0.1:1234/get", &mut writer).unwrap();
  7.   println!("GET");
  8.   println!("Status: {} {}", res.status_code(), res.reason());
  9.   println!("Headers {}", res.headers());
  10.   println!("{}", String::from_utf8_lossy(&writer));
  12.   let mut writer = Vec::new(); //container for body of a response
  13.   const BODY: &[u8; 27] = b"field1=value1&field2=value2";
  14.   // let res = request::post("https://httpbin.org/post", BODY, &mut writer).unwrap();
  15.   // no https , no dns
  16.   let res = request::post("http://127.0.0.1:1234/post", BODY, &mut writer).unwrap();
  18.   println!("POST");
  19.   println!("Status: {} {}", res.status_code(), res.reason());
  20.   println!("Headers {}", res.headers());
  21.   println!("{}", String::from_utf8_lossy(&writer));
  22. }

The following command compiles the Rust program.

cargo build --target wasm32-wasi --release

The following command runs the application in WasmEdge.

wasmedge target/wasm32-wasi/release/http_client.wasm

An HTTP server example

The source code for the HTTP server application is available as follows.

  1. use bytecodec::DecodeExt;
  2. use httpcodec::{HttpVersion, ReasonPhrase, Request, RequestDecoder, Response, StatusCode};
  3. use std::io::{Read, Write};
  4. #[cfg(feature = "std")]
  5. use std::net::{Shutdown, TcpListener, TcpStream};
  6. #[cfg(not(feature = "std"))]
  7. use wasmedge_wasi_socket::{Shutdown, TcpListener, TcpStream};
  9. fn handle_http(req: Request<String>) -> bytecodec::Result<Response<String>> {
  10.   Ok(Response::new(
  11.     HttpVersion::V1_0,
  12.     StatusCode::new(200)?,
  13.     ReasonPhrase::new("")?,
  14.     format!("echo: {}", req.body()),
  15.   ))
  16. }
  18. fn handle_client(mut stream: TcpStream) -> std::io::Result<()> {
  19.   let mut buff = [0u8; 1024];
  20.   let mut data = Vec::new();
  22.   loop {
  23.     let n = stream.read(&mut buff)?;
  24.     data.extend_from_slice(&buff[0..n]);
  25.     if n < 1024 {
  26.       break;
  27.     }
  28.   }
  30.   let mut decoder =
  31.     RequestDecoder::<httpcodec::BodyDecoder<bytecodec::bytes::Utf8Decoder>>::default();
  33.   let req = match decoder.decode_from_bytes(data.as_slice()) {
  34.     Ok(req) => handle_http(req),
  35.     Err(e) => Err(e),
  36.   };
  38.   let r = match req {
  39.     Ok(r) => r,
  40.     Err(e) => {
  41.       let err = format!("{:?}", e);
  42.       Response::new(
  43.         HttpVersion::V1_0,
  44.         StatusCode::new(500).unwrap(),
  45.         ReasonPhrase::new(err.as_str()).unwrap(),
  46.         err.clone(),
  47.       )
  48.     }
  49.   };
  51.   let write_buf = r.to_string();
  52.   stream.write(write_buf.as_bytes())?;
  53.   stream.shutdown(Shutdown::Both)?;
  54.   Ok(())
  55. }
  57. fn main() -> std::io::Result<()> {
  58.   let port = std::env::var("PORT").unwrap_or(1234.to_string());
  59.   println!("new connection at {}", port);
  60.   let listener = TcpListener::bind(format!("0.0.0.0:{}", port))?;
  61.   loop {
  62.     let _ = handle_client(listener.accept()?.0);
  63.   }
  64. }

The following command compiles the Rust program.

cargo build --target wasm32-wasi --release

The following command runs the application in WasmEdge.

$ wasmedge target/wasm32-wasi/release/http_server.wasm new connection at 1234

To test the HTTP server, you can submit a HTTP request to it via curl.

$ curl -d "name=WasmEdge" -X POST http://127.0.0.1:1234 echo: name=WasmEdge