RTT会向所谓的物联网操作系统发展吗

发布于 2015-07-24 22:36:05 浏览：3527 订阅该版

6 个回答

bernard 2015-07-26

这家伙很懒，什么也没写！

cmjs 2015-08-07

这家伙很懒，什么也没写！

bernard 2015-08-07

这家伙很懒，什么也没写！

cmjs 2015-08-08

这家伙很懒，什么也没写！

>>coap可以参考这个  原来做mesh的时候 看过
>>
>>[https://github.com/1248/microcoap](https://github.com/1248/microcoap)
>
>---
>
>
>
>谁帮忙移植一个？目前cloudide可以关联外部git了，后面加入更多的packages

---

由于udp那一套东西都是现成的   所以如果是运行他的那个例子的话   只需要 coap.c coap.h endpoint.c  main_posix.c  这四个文件就可以了
前三个文件只需要添加一些rtt的头文件  把printf 定义为rt_kprintf   还有一些string函数换成  rt_xxx 就可以了
最后一个文件可以参考udp_server的例子  把它放在finsh中启动

```

#include <rtthread.h>	  // 
#include <lwip/sockets.h> //  
//#include <stdio.h>	  //
//#include <stdbool.h>	  //

#include "coap.h"

#define PORT 5683

void coap_server_thread(void* para)
{
    int fd;
    struct sockaddr_in servaddr, cliaddr;
    static uint8_t buf[4096];
    static uint8_t scratch_raw[4096];    
    coap_rw_buffer_t scratch_buf = {scratch_raw, sizeof(scratch_raw)};

if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) 
    {
        rt_kprintf("Socket Error
");
        return;
    }

servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(PORT);
    rt_memset(&(servaddr.sin_zero), 0, sizeof(servaddr.sin_zero));
    
    if ((bind(fd, (struct sockaddr *)&servaddr, sizeof(servaddr))) == -1)
    {
       rt_kprintf("Bind error
");
       return;        
    }

endpoint_setup();
    rt_kprintf("Coap Server Start!
");
    while(1)
    {
        int n, rc;
        socklen_t len = sizeof(cliaddr);
        coap_packet_t pkt;

n = recvfrom(fd, buf, sizeof(buf), 0, (struct sockaddr *)&cliaddr, &len);
#ifdef DEBUG
        rt_kprintf("
--------------------
");
        rt_kprintf("Received Buffer: 
");
        coap_dump(buf, n, true);
        rt_kprintf("
");
#endif

if (0 != (rc = coap_parse(&pkt, buf, n)))	   // 将接收到的UDP数据  放到  coap_packet包中
        {
            rt_kprintf("Bad packet rc=%d
", rc);
        }
        else
        {
            size_t rsplen = sizeof(buf);
            coap_packet_t rsppkt;	                     // 这是要  回复的包
#ifdef DEBUG
            rt_kprintf("Dump Packet: 
");
            coap_dumpPacket(&pkt);
#endif
            coap_handle_req(&scratch_buf, &pkt, &rsppkt);	   //  处理接收包  并建立 rsppkt

if (0 != (rc = coap_build(buf, &rsplen, &rsppkt)))	 // 利用rsppkt 建立udp回应包
            {
                 rt_kprintf("coap_build failed rc=%d
", rc);
            }
            else
            {
#ifdef DEBUG
                rt_kprintf("--------------------
");
                rt_kprintf("Sending Buffer: 
");
                coap_dump(buf, rsplen, true);
                rt_kprintf("
");
#endif
#ifdef DEBUG
                coap_dumpPacket(&rsppkt);
#endif
                sendto(fd, buf, rsplen, 0, (struct sockaddr *)&cliaddr, sizeof(cliaddr));
            }
        }
    }
}

void coap_server()
{
	rt_thread_t tid;
	tid = rt_thread_create("coap_server", coap_server_thread, RT_NULL,
		1024, 25, 5);
	if (tid != RT_NULL) rt_thread_startup(tid);
}
#ifdef RT_USING_FINSH
#include <finsh.h>
FINSH_FUNCTION_EXPORT(coap_server, startup coap server);
#endif

```

下面这个是在安装了coap插件的火狐浏览器中 输入 ["coap://192.168.1.104/light"](coap://192.168.1.104/light) 的结果
串口输出的结果

```
coap_server      -- startup coap server
finsh>>coap_server()
        0, 0x00000000
finsh>>Coap Server Start!

--------------------
Received Buffer: 
40 01 38 AD B5 6C 69 67 68 74 C1 02
Dump Packet: 
Header:
  ver  0x01
  t    0x00
  tkl  0x00
  code 0x01
  id   0x38AD
 Options:
  0x0B [ 6C 69 67 68 74 ]
  0x17 [ 02 ]
Payload: 
--------------------
Sending Buffer: 
60 45 38 AD C2 00 00 FF 30
Header:
  ver  0x01
  t    0x02
  tkl  0x00
  code 0x45
  id   0x38AD
 Options:
  0x0C [ 00 00 ]
Payload: 30
```