[dependencies] gpio-cdev = “0.4”
Categories
[dependencies] gpio-cdev = “0.4”
curl –proto ‘=https’ –tlsv1.2 -sSf https://sh.rustup.rs | sh
. “$HOME/.cargo/env”
lsblk # 查看磁盘和分区信息
df -h # 查看文件系统使用情况
输出
NAME MAJ:MIN RM SIZE RO TYPE MOUNTPOINT
mmcblk0 179:0 0 64G 0 disk
├─mmcblk0p1 179:1 0 256M 0 part /boot
└─mmcblk0p2 179:2 0 8G 0 part / # 仅用了 8G,剩余空间未分配
/ 代表的就是跟文件系统分区 要扩容就是这个分区扩容
sudo resize2fs /dev/mmcblk0p2 # 扩展 ext4 文件系统
sudo mount -o loop rootfs.img ~/mount_dir
挂载镜像到某个目录
sudo vim /etc/shadow
修改密码文件
root:!:19475:0:99999:7:::
!或*代表该账号无法登录
数据段说明
用户名:加密密码:最后修改时间:最小密码年龄:最大密码年龄:警告期:不活动期:过期时间:保留字段
mkpasswd -m sha-512
执行该命令然后输入密码 替换上面的加密密码段
/etc/ssh/sshd_config
修改配置文件
PermitRootLogin yes # 修改后重启 SSH 服务:sudo systemctl restart sshd
设置允许root 密码登录
在嵌入式Linux系统中,U-Boot、Kernel(内核)和Rootfs(根文件系统) 是三个核心组件,它们分工协作,共同完成系统启动和运行。以下是它们的相互关系和作用:
zImage
或uImage
)和设备树(dtb
)到内存。/
目录。init
或 systemd
,PID=1)。root=
指定Rootfs位置)。/bin
、/sbin
)。/etc
)。/lib
)。/usr
)。root=/dev/mmcblk0p2
)挂载。/sbin/init
或 /lib/systemd/systemd
(第一个用户进程)。console=ttyS0 root=/dev/nfs
)。init
进程,进入用户空间,完成系统启动。/bin/sh
缺失)。通过三者协同,嵌入式系统从硬件上电到完整启动,最终运行应用程序。
第一步 安装tokio库
cargo add tokio --features full
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::net::{TcpListener, TcpStream};
use std::error::Error;
#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
// 绑定到本地地址的8080端口
let listener = TcpListener::bind("127.0.0.1:8080").await?;
println!("服务器正在监听 127.0.0.1:8080");
loop {
// 等待新的连接
let (socket, addr) = listener.accept().await?;
println!("接收到来自 {} 的新连接", addr);
// 为每个连接生成一个新任务
tokio::spawn(async move {
if let Err(e) = handle_connection(socket).await {
println!("处理连接时出错: {}", e);
}
});
}
}
async fn handle_connection(mut socket: TcpStream) -> Result<(), Box<dyn Error>> {
// 创建一个缓冲区来存储数据
let mut buf = [0; 1024];
loop {
// 读取数据
let size = match socket.read(&mut buf).await {
// 客户端关闭了连接
Ok(size) if size == 0 => return Ok(()),
Ok(size) => size,
Err(e) => {
return Err(e.into());
}
};
let data = &buf[..size];
let received = String::from_utf8_lossy(data);
println!("Received data: {}", received);
// 检查是否是telnet的断开命令(IAC IP)
if size >= 3 && buf[0] == 255 && buf[1] == 244 {
println!("Detected telnet disconnect command (IAC IP)");
//显示关闭连接并且传播异常
socket.shutdown().await?;
//这个也能退出事件循环 关闭连接
return Ok(());
}
// 检查普通ASCII的CTRL+C (3)
if buf[..size].contains(&3) {
println!("Detected CTRL+C, closing connection");
//显示关闭连接并且传播异常
socket.shutdown().await?;
//这个也能退出事件循环 关闭连接
return Ok(());
}
println!("接收到 {} 字节数据", size);
// 将数据写回客户端
if let Err(e) = socket.write_all(&buf[0..size]).await {
return Err(e.into());
}
}
}
本地 kubernetes dashboard访问路径 https://kubernetes.local/
本地nexus访问路径 http://nexus.local/
本地kibana访问路径 http://kibana.local/app/home
本地grafana访问路径 http://grafana.local/
使用blender画模型后
导出STL文件 然后bamboo connect 加载STL发送打印任务到 3D打印机
服务端代码:socket阻塞循环读
use std::io::{Read, Write};
use std::net::{TcpListener,TcpStream};
use std::thread;
fn handle_client(mut stream: TcpStream) {
let mut buffer = [0; 1024];
loop {
match stream.read(&mut buffer) {
Ok(0) => {
// 客户端关闭连接
println!("Client disconnected");
break;
}
Ok(size) => {
// 读取到数据,回显给客户端
let data = &buffer[..size];
let received = String::from_utf8_lossy(data);
println!("Received data: {}", received);
// 检查是否是telnet的断开命令(IAC IP)
if size >= 3 && buffer[0] == 255 && buffer[1] == 244 {
println!("Detected telnet disconnect command (IAC IP)");
if let Err(e) = stream.shutdown(std::net::Shutdown::Both) {
println!("Error shutting down stream: {}", e);
}
break;
}
// 检查普通ASCII的CTRL+C (3)
if buffer[..size].contains(&3) {
println!("Detected CTRL+C, closing connection");
if let Err(e) = stream.shutdown(std::net::Shutdown::Both) {
println!("Error shutting down stream: {}", e);
}
break;
}
if let Err(e) = stream.write_all(&buffer[..size]) {
println!("Error writing to stream: {}", e);
break;
}
}
Err(e) => {
// 发生错误,关闭连接
println!("Error: {}", e);
break;
}
}
}
}
fn main() {
let listener = TcpListener::bind("127.0.0.1:65432").unwrap();
println!("Server listening on 127.0.0.1:65432");
for stream in listener.incoming() {
match stream {
Ok(stream) => {
// 为每个客户端连接创建一个新线程
thread::spawn(move || {
handle_client(stream);
});
}
Err(e) => {
println!("Error accepting stream: {}", e);
break;
}
}
}
// 注意:在实际应用中,应该优雅地关闭监听器,比如监听一个关闭信号。
// 这里为了简化,直接退出主循环后程序将结束。
}
client 端代码
use std::io::{self, Read, Write};
use std::net::TcpStream;
fn main() -> io::Result<()> {
let mut stream = TcpStream::connect("127.0.0.1:65432")?;
println!("Connected to server!");
loop {
let mut input = String::new();
io::stdin().read_line(&mut input)?;
if input.contains('\x03') { // CTRL+C
println!("Sending CTRL+C to server");
stream.write_all(input.as_bytes())?;
break;
}
stream.write_all(input.as_bytes())?;
let mut buffer = [0; 1024];
let size = stream.read(&mut buffer)?;
if size == 0 {
println!("Server closed connection");
break;
}
println!("Server echo: {}", String::from_utf8_lossy(&buffer[..size]));
}
Ok(())
}