uip UDP 服務(wù)器廣播模式(客戶端可以任意端口,并且主動(dòng)向客戶端發(fā)送數(shù)據(jù))

目前移植uip,發(fā)現(xiàn)UDP 服務(wù)器模式下,必須指定本地端口以及客戶端端口,否則只能講客戶端端口設(shè)置為0,才能接收任意端口的數(shù)據(jù),但是無法發(fā)送數(shù)據(jù),因?yàn)榇藭r(shí)客戶端端口設(shè)置為0了,我通過將原始數(shù)據(jù)包中的客戶端端口保存下來,并且在發(fā)送的時(shí)候?qū)⒖蛻舳硕丝谔鎿Q為指定的端口,發(fā)送完成之后又設(shè)置為0,這樣就實(shí)現(xiàn)了向任意客戶端端口發(fā)送數(shù)據(jù).

uip.c

????if(uip_udp_conn->lport?!=?0?&&
???????UDPBUF->destport?==?uip_udp_conn->lport?&&
???????(uip_udp_conn->rport?==?0?||
????????UDPBUF->srcport?==?uip_udp_conn->rport)?&&
???????(uip_ipaddr_cmp(uip_udp_conn->ripaddr,?all_zeroes_addr)?||
	uip_ipaddr_cmp(uip_udp_conn->ripaddr,?all_ones_addr)?||
	uip_ipaddr_cmp(BUF->srcipaddr,?uip_udp_conn->ripaddr)))?{

?(uip_udp_conn->rport?==?0?||
????????UDPBUF->srcport?==?uip_udp_conn->rport)?&&

這句就限制了客戶端端口為0或者指定端口

//udp_server.c

/*************************************************************************************************************
?*?文件名:			udp_server.h
?*?功能:			uIP?UDP服務(wù)器相關(guān)函數(shù)
?*?作者:			cp1300@139.com
?*?創(chuàng)建時(shí)間:		2014-06-04
?*?最后修改時(shí)間:	2014-06-04
?*?詳細(xì):			UDP服務(wù)器相關(guān)函數(shù)
*************************************************************************************************************/	
#include?"SYSTEM.h"
#include?"tapdev.h"
#include?"uip.h"
#include#include	#include?"uIP_user.h"
#include?"udp_server.h"
#include?"appconfig.h"

u16?UDP_ServerPort?=?UDP_SERVER_PORT;			//UDP服務(wù)器本地端口,用于新數(shù)據(jù)端口識(shí)別
UIP_USER?udp_server;							//UDP?服務(wù)器數(shù)據(jù)結(jié)構(gòu)
static?bool?isAnyPort?=?FALSE;					//客戶端任意端口標(biāo)志



/*************************************************************************************************************************
*?函數(shù)			:	void?udp_server_connected(u16?ServerPort,u16?ClientPort)
*?功能			:	建立一個(gè)UDP服務(wù)器(廣播方式)
*?參數(shù)			:	ServerPort:服務(wù)器本地端口,ClientPort:客戶端端口,0:任意端口;非0:指定端口
*?返回			:	無
*?依賴			:	uip
*?作者			:	cp1300@139.com
*?時(shí)間			:	2014-06-04
*?最后修改時(shí)間	:?	2014-06-05
*?說明			:?	必須放在UDP客戶端初始化之前
*************************************************************************************************************************/
void?udp_server_connected(u16?ServerPort,u16?ClientPort)
{
	UDP_ServerPort?=?ServerPort;							//本地端口
	uip_listen(HTONS(ServerPort));
	uip_udp_bind(&uip_udp_conns[0],?htons(ServerPort));		//綁定本地端口
	udp_server.RxLen?=?0;
	udp_server.TxLen?=?0;
	udp_server.ServerPort?=?ServerPort;						//服務(wù)器端口
	if(ClientPort?!=?0)										//指定端口
	{
		uip_udp_conns[0].rport?=?HTONS(ClientPort);
		udp_server.ClientPort?=?ClientPort;
		isAnyPort?=?FALSE;									//客戶端指定端口
	}
	else
	{
		uip_udp_conns[0].rport?=?0;
		isAnyPort?=?TRUE;									//客戶端任意端口
	}
}




/*************************************************************************************************************************
*?函數(shù)			:	void?udp_server_appcall(void)
*?功能			:	服務(wù)器回調(diào)函數(shù),用于uip處理數(shù)據(jù)
*?參數(shù)			:	無
*?返回			:	無
*?依賴			:	uip
*?作者			:	cp1300@139.com
*?時(shí)間			:	2014-06-04
*?最后修改時(shí)間	:?	2014-06-05
*?說明			:?	無
*************************************************************************************************************************/
void?udp_server_appcall(void)
{
	
	if?(uip_newdata())
????{
		if(uip_datalen()?>?UIP_RX_BUFF_ZISE)?uip_len?=?UIP_RX_BUFF_ZISE;	//限制大小
		memcpy(udp_server.RxBuff,?uip_appdata,?uip_len);					//復(fù)制接收的數(shù)據(jù)到接收緩沖區(qū)
		udp_server.RxLen?=?uip_len;											//存儲(chǔ)接收數(shù)據(jù)長(zhǎng)度
		udp_server.ClientPort?=?(u16)(uip_buf[34]<UIP_TX_BUFF_ZISE)?len?=?UIP_TX_BUFF_ZISE;
	memcpy(udp_server.TxBuff,?pBuff,?len);
	udp_server.TxLen?=?len;
	uip_udp_conns[0].rport?=?HTONS(ClientPort);			//暫時(shí)將客戶端端口設(shè)置為上一次發(fā)送數(shù)據(jù)的客戶端端口
}




/*************************************************************************************************************************
*?函數(shù)			:	void?udp_ServerSendEndCallBack(u16?conn)
*?功能			:	UDP發(fā)送數(shù)據(jù)完成回調(diào)函數(shù),目前只支持一個(gè)服務(wù)器端口
*?參數(shù)			:	pBuff:發(fā)送數(shù)據(jù)緩沖區(qū),len:發(fā)送數(shù)據(jù)長(zhǎng)度,ClientPort:客戶端端口
*?返回			:	無
*?依賴			:	uip
*?作者			:	cp1300@139.com
*?時(shí)間			:	2014-06-04
*?最后修改時(shí)間	:?	2014-06-05
*?說明			:?	由于UDP服務(wù)器的客戶端IP設(shè)置為0后可以接收任意端口發(fā)來的數(shù)據(jù),但是卻無法發(fā)送數(shù)據(jù)
					到0端口,因此在發(fā)送前將客戶端端口設(shè)置為實(shí)際端口,發(fā)送完成后修改為0
*************************************************************************************************************************/
void?udp_ServerSendEndCallBack(u16?conn)
{
	if((conn?==?0)?&&?(isAnyPort?==?TRUE))
	{
		uip_udp_conns[conn].rport?=?0;		//將端口設(shè)置為0
	}
}

//udp_server.h

/*************************************************************************************************************
?*?文件名:			udp_server.h
?*?功能:			uIP?UDP服務(wù)器相關(guān)函數(shù)
?*?作者:			cp1300@139.com
?*?創(chuàng)建時(shí)間:		2014-06-04
?*?最后修改時(shí)間:	2014-06-04
?*?詳細(xì):			UDP服務(wù)器相關(guān)函數(shù)
*************************************************************************************************************/	
#ifndef?_UDP_SERVER_H_
#define?_UDP_SERVER_H_
#include?"tcp.h"
#include?"uip.h"
#include?"system.h"
#include?"uIP_user.h"

extern?UIP_USER?udp_server;	//UDP?服務(wù)器數(shù)據(jù)結(jié)構(gòu)
extern?u16?UDP_ServerPort;	//UDP服務(wù)器本地端口


void?udp_server_connected(u16?ServerPort,u16?ClientPort);				//建立一個(gè)UDP服務(wù)器(廣播方式)
void?udp_server_appcall(void);											//服務(wù)器回調(diào)函數(shù),用于uip處理數(shù)據(jù)
void?udp_ServerSendDataPackage(u8?*pBuff,?u16?len,u16?ClientPort);		//UDP?服務(wù)器發(fā)送數(shù)據(jù)
void?udp_ServerSendEndCallBack(u16?conn);								//UDP發(fā)送數(shù)據(jù)完成回調(diào)函數(shù)




#endif?//_UDP_SERVER_H_

//結(jié)構(gòu)體定義

//用戶連接數(shù)據(jù)結(jié)構(gòu)
#define?UIP_RX_BUFF_ZISE	512		//接收數(shù)據(jù)緩沖區(qū)大小
#define?UIP_TX_BUFF_ZISE	512		//發(fā)送數(shù)據(jù)緩沖區(qū)大小
typedef?struct
{
	u16?RxLen;		//接收數(shù)據(jù)長(zhǎng)度
	u16	TxLen;		//發(fā)送數(shù)據(jù)長(zhǎng)度
	u16?ClientPort;	//客戶端端口
	u16	ServerPort;	//服務(wù)器端口
	u8	RxBuff[UIP_RX_BUFF_ZISE];	//接收緩沖區(qū)
	u8	TxBuff[UIP_TX_BUFF_ZISE];	//接收緩沖區(qū)
}UIP_USER;

//配置定義

#define?DHCP_TIME_OUT				60					//DHCP獲取超時(shí)時(shí)間,單位S
#define?TCP_LINK_SERVER_TIME_OUT	10					//連接服務(wù)器超時(shí)時(shí)間,單位S
#define?TCP_LINK_SERVER_CNT			5					//連接服務(wù)器重試次數(shù)
#define?TCP_CLIENT_PORT_AUTO		1					//客戶端端口隨機(jī)分配
#define?TCP_CLIENT_DEFAULT_PORT		2400				//客戶端默認(rèn)端口
#define?TCP_SERVER_DEFAULT_IP		192,168,16,104		//服務(wù)器默認(rèn)IP地址
#define?TCP_SERVER_DEFAULT_PORT		8888				//服務(wù)器默認(rèn)端口
#define?TCP_SEND_TIME_OUT			5					//數(shù)據(jù)發(fā)送超時(shí)時(shí)間,單位S

#define?UDP_LOCAL_PORT				8000				//UDP連接本地端口
#define?UDP_REMOTE_PORT				8899				//UDP連接遠(yuǎn)程端口
#define?UDP_SERVER_PORT				8100				//UDP服務(wù)器本地端口

//數(shù)據(jù)端口調(diào)度

//UDP應(yīng)用接口函數(shù)(UIP_UDP_APPCALL)
void?udp_appcall(void)
{	

	switch(uip_udp_conn->lport)//本地監(jiān)聽端口
	{
		//用于DHCP
		case?HTONS(67):	dhcpc_appcall();break;
		case?HTONS(68):	?dhcpc_appcall();break;
		default:?
		{
			if(uip_udp_conn->lport?==?HTONS(UDP_ClinetPort))		//UDP客戶端
			{
				udp_client_appcall();
			}
			else?if(uip_udp_conn->lport?==?HTONS(UDP_ServerPort))	//UDP服務(wù)器
			{
				udp_server_appcall();
			}
		}break;
	}		??????
}

//UDP調(diào)度處理,必須在數(shù)據(jù)發(fā)送完成后調(diào)用自定義的回調(diào)函數(shù)

			for(i?=?0;?i?<?UIP_UDP_CONNS;?i++)
			{
				//只處理發(fā)送事件
				uip_udp_periodic(i);	//處理UDP通信事件
				//當(dāng)上面的函數(shù)執(zhí)行后，如果需要發(fā)送數(shù)據(jù)，則全局變量uip_len>0
				//需要發(fā)送的數(shù)據(jù)在uip_buf,?長(zhǎng)度是uip_len?(這是2個(gè)全局變量)
				if(uip_len?>?0)
				{
					LED2?=?~?LED2;
					uip_arp_out();//加以太網(wǎng)頭結(jié)構(gòu)，在主動(dòng)連接時(shí)可能要構(gòu)造ARP請(qǐng)求
					tapdev_send();//發(fā)送數(shù)據(jù)到以太網(wǎng)
					udp_ServerSendEndCallBack(i);	//數(shù)據(jù)發(fā)送完成后一定要調(diào)用回調(diào)函數(shù)
					break;
				}
			}

調(diào)用這個(gè)實(shí)現(xiàn)將客戶端端口設(shè)置為0,這樣就可以接受來自任意端口的數(shù)據(jù)

udp_ServerSendEndCallBack(i);	//數(shù)據(jù)發(fā)送完成后一定要調(diào)用回調(diào)函數(shù)

//初始化并處理UDP服務(wù)器數(shù)據(jù)

//實(shí)現(xiàn)收到后立即返回?cái)?shù)據(jù)

udp_server_connected(UDP_SERVER_PORT,?0);	//新建UDP服務(wù)器,客戶端任意端口

//UDP服務(wù)器數(shù)據(jù)處理
		if(udp_server.RxLen?>?0)
		{
			
			uart_printf("服務(wù)器端口:%drn",udp_server.ServerPort);
			uart_printf("客戶端端口:%drn",udp_server.ClientPort);
			uart_printf("UDP?Server?Rx(%dB):%srn",udp_server.RxLen,(char*)udp_server.RxBuff);
			udp_ServerSendDataPackage(udp_server.RxBuff,?udp_server.RxLen,?udp_server.ClientPort);
			udp_server.RxLen?=?0;
		}

//仿真結(jié)果