typedef struct{
  uint16_t from_id;   // 2
  uint16_t to_id;     // 2
  uint8_t type;       // 1
  char data[20];      // 20
  char *p_data;       // 4
}Message;

QueueHandle_t queueMsg = xQueueCreate(8, sizeof(Message));   // 创建消息队列，长度为8，每条消息大小为20字节
//char data[20]="This is message!";
// 模拟数据分发服务器动作
void server_task(void* param_t){
  char data[20]="This is message!";
  Message msg;
  msg.from_id=1;
  msg.to_id=100;
  msg.type=2;
  strcpy(msg.data, data);
  msg.p_data = data;

  if(xQueueSend(queueMsg, &msg, portMAX_DELAY) == pdPASS){
    printf("[SEND] 消息发送成功: 0x%p\n", &msg);//printf使用串口
    printf("[SEND] data指针：0x%p\n",msg.data);
    printf("[SEND] p_data指针：0x%p\n",&msg.p_data);
    printf("[SEND] p_data值：0x%p\n",msg.p_data);
    printf("[SEND] data value :%s\n", msg.data);
  }
  vTaskDelete(NULL);
}

// 模拟客户端运算器，用于获取消息
void client_task(void* param_t){
  Message msg;
  if(xQueueReceive(queueMsg, &msg, portMAX_DELAY)==pdPASS){
    printf("[RECV] 消息接收完毕： 0x%p\n", &msg);
    printf("[RECV] data指针：0x%p\n",msg.data);
    printf("[RECV] p_data指针：0x%p\n",&msg.p_data);
    printf("[RECV] p_data值：0x%p\n",msg.p_data);
    printf("[RECV] data value :%s\n", msg.p_data);
  }
  vTaskDelete(NULL);
}

void setup() {
  Serial.begin(115200);
  Serial.println("Hello, ESP32-S3!");
  // 创建发送和接收任务
  xTaskCreate(server_task, "Sender", 1024 * 8, NULL, 1, NULL);
  xTaskCreate(client_task, "Receiver", 1024 * 8, NULL, 1, NULL);
}

void loop() {
  delay(10); 
}