ART网络相关说明

发布于 2012-11-18 12:21:43 浏览：4979 订阅该版

5 个回答

bernard 2012-11-18

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

bernard 2012-11-18

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

因为ART wifi shield带了TF（microSD）卡的插槽，插入TF卡将是ART上巨大的存储空间（RT-Thread ART最大可以支持32G的卡），所以可以把用户程序直接存放在TF卡上。

为此编写了一个系统常驻的守护线程：daemon，它会监听端口2000。可以由PC上的客户端push一个文件到ART TF卡上。daemon最初版的代码如下：

```

#include <rtthread.h>

#ifdef RT_USING_LWIP
#include <lwip/sockets.h>
#include <dfs_posix.h>

#define SESSION_MAX	5
#define BUF_SZ		1024

#define FILE_PATH   "/sd"

struct client_request
{
	int socket;

rt_uint32_t filesz;
	rt_uint8_t  filename[64];
};

static rt_uint16_t client_session = 0;
void client_thread(void* parameter)
{
	int fd;
	rt_uint32_t level;
	rt_uint32_t recv_length;
	rt_uint8_t *buf_ptr = RT_NULL;
	struct client_request* request;
	rt_uint8_t fn_full[64];

request = (struct client_request*) parameter;
	RT_ASSERT(request != RT_NULL);

buf_ptr = (rt_uint8_t*) rt_malloc (BUF_SZ);
	if (buf_ptr == RT_NULL) goto __exit;

rt_snprintf(fn_full, sizeof(fn_full), "%s/%s", FILE_PATH, request->filename);
	rt_kprintf("open file: %s
", fn_full);

fd = open(fn_full, O_RDWR | O_TRUNC, 0);
	if (fd >= 0)
	{
		while (1)
		{
			recv_length = lwip_recv(request->socket, buf_ptr, BUF_SZ, 0);
			if (recv_length <= 0)
			{
				break;
			}

rt_kprintf("write %d data.
", recv_length);
			write(fd, buf_ptr, recv_length);
		}
	}

__exit:
	if (buf_ptr != RT_NULL) 
		rt_free(buf_ptr);
	if (request != RT_NULL)
		rt_free(request);
	if (fd >= 0)
	{
		rt_kprintf("close file.
");
		close(fd);
	}
	
	level = rt_hw_interrupt_disable();
	client_session --;
	rt_hw_interrupt_enable(level);

return;
}

void daemon_thread(void* parameter)
{
	int timeout;
	int sock, client;
	rt_uint32_t level;
	rt_uint32_t sin_size;
	struct sockaddr_in server_addr, client_addr;

sin_size = sizeof(struct sockaddr_in);

/* create server socket */
	if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
	   rt_kprintf("Socket error
");
	   return;
	}

server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(2000);
	server_addr.sin_addr.s_addr = INADDR_ANY;
	rt_memset(&(server_addr.sin_zero),8, sizeof(server_addr.sin_zero));

if (lwip_bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
	{
	   rt_kprintf("Unable to bind
");
	   lwip_close(sock);
	   return;
	}

if (lwip_listen(sock, 5) == -1)
	{
	   rt_kprintf("Listen error
");
	   lwip_close(sock);
	   return;
	}

while(1)
	{
		client = lwip_accept(sock, (struct sockaddr *)&client_addr, &sin_size);
		if (client >= 0)
		{
			struct client_request* request;

level = rt_hw_interrupt_disable();
			if (client_session >= SESSION_MAX)
			{
				rt_hw_interrupt_enable(level);
				continue;
			}
			rt_hw_interrupt_enable(level);

request = (struct client_request*) rt_malloc (sizeof(struct client_request));
			if (request != RT_NULL)
			{
				rt_thread_t tid;

/* set recv timeout */
				timeout = 3000; /* 3 seconds */				
				lwip_setsockopt(client, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout));
				if (lwip_recv(client, request, sizeof(struct client_request), 0) != sizeof(struct client_request))
				{
					 lwip_close(client);
					 rt_free(request);
				}
				else
				{
					/* set client socket */
					request->socket = client;
					tid = rt_thread_create("client", client_thread, (void*) request, 
						1024, 30, 10);
					if (tid != RT_NULL)
					{

level = rt_hw_interrupt_disable();
						client_session ++;
						rt_hw_interrupt_enable(level);
						rt_thread_startup(tid);
					}
					else
					{
						/* create thread failed. */
						lwip_close(client);
						rt_free(request);
					}
				}			
			}
		}
	}

lwip_close(sock);

return ;
}

int daemon(void)
{
	rt_thread_t tid;

tid = rt_thread_create("daemon", daemon_thread, RT_NULL,
		1024, 20, 10);
	if (tid != RT_NULL)
		rt_thread_startup(tid);

return 0;
}
#ifdef RT_USING_FINSH
#include <finsh.h>
FINSH_FUNCTION_EXPORT(daemon, startup daemon server);
#endif

#endif

```

PC上使用python编写的客户端代码如下：

```

#! /usr/bin/env python
#coding=utf-8

import sys
import time 
import struct
import os

from socket import socket
from socket import AF_INET
from socket import SOCK_STREAM

PORT = 2000

def daemon_client(filename, host):
    addr = (host,PORT)
    TCPSock = socket(AF_INET, SOCK_STREAM)
    
    try:
        TCPSock.connect(addr)
    except:
        print 'connect TCP server: %s failed.' % host
        exit(0)
    
    total_length = 0
    f = file(filename, 'rb')
    if f:
        f.seek(0, os.SEEK_END)
        length = f.tell()
        f.seek(0, os.SEEK_SET)
        
        request = struct.pack('II64s', 0, length, filename)
        TCPSock.send(request)
        
        print 'Push file to device',
        while True:
            data = f.read(1024)
            if not data:
                break
            TCPSock.send(data)
            print '.',
        print 'Done.'

TCPSock.close()
    
if __name__ == '__main__':
    if len(sys.argv) != 3:
        print 'Usage:push file host'
        exit(0)

fn = sys.argv[1]
    host = sys.argv[2]
    
    daemon_client(fn, host)

```

使用方法，例如这个脚本名称是push.py，则执行push youapp.mo 192.168.0.30

bernard 2012-11-18

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

WIFI这块，同样支持静态IP和动态IP。

如果是Arduino程序来启动（初始化）WIFI，可以使用如下方法：
静态IP形式

```

#include <Arduino.h>
#include <WiFi.h>
#include <Ethernet.h>

char ssid[] = "RT-Thread_11N";     //  your network SSID (name) 
char pass[] = "finsh";                    // your network password
char mac[] = {0x11, 0x22, 0x33, 0x44, 0x55, 0x66};
byte ip[] = { 192, 168, 0, 30 };

void setup() {
  int status;
  status = WiFi.begin(ssid, pass);
  if (status == WL_CONNECTED)
    Serial.print("You're connected to the network");
  Ethernet.begin(mac, ip);
}

void loop() {
  exit(0);
}

```

注意这里仅指定了ART_device的地址，指定为192.168.0.30，但网关地址，子网掩码，DNS服务器地址都未指定（Arduino Ethernet API支持这种形式），这个会在ART中自动指定网关地址为192.168.0.1，子网掩码为255.255.255.0。同时ART中会内置一个DNS服务器地址。

动态DHCP形式

```

#include <Arduino.h>
#include <WiFi.h>

char ssid[] = "RT-Thread_11N";     //  your network SSID (name) 
char pass[] = "finsh";                    // your network password

void setup() {
  int status;
  status = WiFi.begin(ssid, pass);
  if (status == WL_CONNECTED)
    Serial.print("You're connected to the network");
}

void loop() {
  exit(0);
}

```

注：exit函数是ART所自行添加，当使用exit函数时，用户模块会退出，而不是类似Arduino那样傻傻地loop。<ART是多任务Arduino程序运行，一个程序退出了很正常>