int sockfd;if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {perror("socket 创建出错！");exit(1);}

struct sockaddr_in {short int sin_family;unsigned short int sin_port;struct in_addr sin_addr;unsigned char sin_zero[8];
};

struct sockaddr_in name;int sockfd;if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {exit(1);}name.sin_family = AF_INET;name.sin_port = htons(8087);name.sin_addr.s_addr = htonl(INADDR_ANY);bzero(&(name.sin_zero), 8); /* zero out the rest of the space */if (bind(sockfd, (struct sockaddr *) &name, sizeof(struct sockaddr))== -1) {exit(1);}

if (connect(sockfd, (struct sockaddr *) &name, sizeof(name)) < 0) {  exit(1); }

if (listen(sockfd, 20) == -1) { exit(1); }

conn = accept(sockfd, (struct sockaddr*) &name, sizeof(name));if (conn < 0) {exit(1);}

char buffer[BUFFER_SIZE];
while (1) {memset(buffer, 0, sizeof(buffer));int len = recv(conn, buffer, sizeof(buffer), 0);if (strcmp(buffer, "exit\n") == 0)break;fputs(buffer, stdout);send(conn, buffer, len, 0);}

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <netdb.h>
#include <arpa/inet.h>//for inet_ntoa
#include <unistd.h>//for fork()#define SERVER_PORT 6666
#define LISTEN_QUEUE  20
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512int main() {//设置一个socket地址结构server_addr,代表服务器internet地址, 端口struct sockaddr_in server_addr;bzero(&server_addr, sizeof(server_addr)); //把一段内存区的内容全部设置为0server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htons(INADDR_ANY);server_addr.sin_port = htons(SERVER_PORT);//创建用于internet的流协议(TCP)socket,用server_socket代表服务器socketint server_socket = socket(PF_INET, SOCK_STREAM, 0);if (server_socket < 0) {printf("Create Socket Failed!");exit(1);}//把socket和socket地址结构联系起来if (bind(server_socket, (struct sockaddr*) &server_addr,sizeof(server_addr))) {printf("Server Bind Port: %d Failed!\n", SERVER_PORT);exit(1);}//server_socket用于监听if (listen(server_socket, LISTEN_QUEUE)) {printf("Server Listen Failed!");exit(1);}while (1) {//定义客户端的socket地址结构client_addrchar buffer[BUFFER_SIZE];struct sockaddr_in client_addr;socklen_t length = sizeof(client_addr);int client_socket = accept(server_socket,(struct sockaddr*) &client_addr, &length);if (client_socket < 0) {printf("Server Accept Failed!\n");break;}bzero(buffer, BUFFER_SIZE);// 获取客户端要传输的文件名length = recv(client_socket, buffer, BUFFER_SIZE, 0);if (length < 0) {printf("Server Recieve Data Failed!\n");break;}char file_name[FILE_NAME_MAX_SIZE + 1];bzero(file_name, FILE_NAME_MAX_SIZE + 1);strncpy(file_name, buffer,strlen(buffer) > FILE_NAME_MAX_SIZE ?FILE_NAME_MAX_SIZE : strlen(buffer));// 新建文件FILE * fp = fopen(file_name, "w");if (NULL == fp) {printf("File: %s CAN NOT WRITE!\n", file_name);} else {bzero(buffer, BUFFER_SIZE);int file_block_length = 0;while ((file_block_length = recv(client_socket, buffer, BUFFER_SIZE,0)) > 0) {if (file_block_length < 0) {printf("Recieve Data From Client Failed!\n");break;}int write_length = fwrite(buffer, sizeof(char),file_block_length, fp);if (write_length < file_block_length) {printf("File: %s Write Failed\n", file_name);break;}bzero(buffer, BUFFER_SIZE);}fclose(fp);printf("File: %s Transfer Finished\n\n", file_name);}close(client_socket);}close(server_socket);return 0;
}

View Code

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <netdb.h>
#include <arpa/inet.h>//for inet_ntoa
#include <unistd.h>//for fork()#define SERVER_PORT 6666
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512int main() {//设置一个socket地址结构client_addr,代表客户机internet地址, 端口struct sockaddr_in client_addr;bzero(&client_addr, sizeof(client_addr)); //把一段内存区的内容全部设置为0client_addr.sin_family = AF_INET; //internet协议族client_addr.sin_addr.s_addr = htons(INADDR_ANY); //INADDR_ANY表示自动获取本机地址client_addr.sin_port = htons(0); //0表示让系统自动分配一个空闲端口//创建用于internet的流协议(TCP)socket,用client_socket代表客户机socketint client_socket = socket(AF_INET, SOCK_STREAM, 0);if (client_socket < 0) {printf("Create Socket Failed!\n");exit(1);}//把客户机的socket和客户机的socket地址结构联系起来if (bind(client_socket, (struct sockaddr*) &client_addr,sizeof(client_addr))) {printf("Client Bind Port Failed!\n");exit(1);}//设置一个socket地址结构server_addr,代表服务器的internet地址, 端口struct sockaddr_in server_addr;bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(SERVER_PORT);socklen_t server_addr_length = sizeof(server_addr);// 向服务器发起连接,连接成功后client_socket代表了客户机和服务器的一个socket连接if (connect(client_socket, (struct sockaddr*) &server_addr,server_addr_length) < 0) {exit(1);}// 连接上服务器, 选择要上传的文件char file_name[FILE_NAME_MAX_SIZE + 1];bzero(file_name, FILE_NAME_MAX_SIZE + 1);printf("Please Input File Name Upload To Server: ");scanf("%s", file_name);char buffer[BUFFER_SIZE];bzero(buffer, BUFFER_SIZE);strncpy(buffer, file_name,strlen(file_name) > BUFFER_SIZE ? BUFFER_SIZE : strlen(file_name));FILE * fp = fopen(file_name, "r");if (NULL == fp) {printf("File: %s NOT FOUND! \n", file_name);exit(1);}// 发送文件名int nameLength = send(client_socket, buffer, BUFFER_SIZE, 0);if (nameLength < 0) {printf("File name Error! \n");exit(0);}bzero(buffer, BUFFER_SIZE);int file_block_length = 0;while ((file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp))> 0) {if (send(client_socket, buffer, file_block_length, 0) < 0) {printf("Send File:\t%s Failed\n", file_name);break;}bzero(buffer, BUFFER_SIZE);}printf("File:\t%s Transfer Finished\n", file_name);fclose(fp);close(client_socket);return 0;
}

View Code

HTTP请求格式:
<request-line>
<headers>
<blank line>
[<request-body>]
说明:第一行必须是一个请求行(request-line),用来说明请求类型,要访问的资源以及所使用的HTTP版本.
      紧接着是一个首部(header)小节,用来说明服务器要使用的附加信息.
      之后是一个空行.
      再后面可以添加任意的其他数据[称之为主体(body)].
例1 GET请求:

GET / HTTP/1.1
Accept: */*
Accept-Language: zh-cn
Accept-Encoding: gzip, deflate
User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 2.0.50727; .NET CLR 3.0.04506.648; .NET CLR 3.5.21022)
Host: www.google.cn
Connection: Keep-Alive
说明:请求的第一部分说明了该请求是一个GET请求.该行的第二部分是一个斜杠(/),用来说明请求的是该域名的根目录.该行的最后一部分说明使用的是HTTP1.1版本(另一个可选荐是1.0).
      第2行是请求的第一个首部,HOST将指出请求的目的地.User-Agent,服务器端和客户端脚本都能访问它,它是浏览器类型检测逻辑的重要基础.该信息由你的浏览器来定义,并且在每个请求中自动发送.Connection,通常将浏览器操作设置为Keep-Alive
      第三部分,空行,即使不存在请求主体,这个空行也是必需的.

例2 POST请求:

POST / HTTP1.1
Host:www.wrox.com
User-Agent:Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 2.0.50727; .NET CLR 3.0.04506.648; .NET CLR 3.5.21022)
Content-Type:application/x-www-form-urlencoded
Content-Length:40
Connection: Keep-Alive

name=Professional%20Ajax&publisher=Wiley
说明:请求行开始处的GET改为POST,以表示不同的请求类型.
      Content-Type说明了请求主体的内容是如何编码的.浏览器始终以application/x-www-form-urlencoded的格式编码来传送数据,这是针对简单URL编码的MIME类型.Content-Length说明了请求主体的字节数.
      最后请求主体.名称-值对的形式.

HTTP响应格式:
<status-line>
<headers>
<blank line>
[<response-body>]

HTTP/1.1 200 OK
Date: Fri, 22 May 2009 06:07:21 GMT
Content-Type: text/html; charset=UTF-8

<html>
      <head></head>
      <body>
            <!--body goes here-->
      </body>
</html>
说明:HTTP状态码200,找到资源,并且一切正常.
      Date:生成响应的日期和时间.
      Content-Type:指定了MIME类型的HTML(text/html),编码类型是UTF-8
      HTML源文体.

#include <cstdio>
#include <stdlib.h>
#include <errno.h>
#include <cstring>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <time.h>
#include <arpa/inet.h>//for inet_ntoa
#include <unistd.h>//for fork()#define MAXN 20480struct INFO {char ID[50], psw[50];
};int analysis_packet(char *packet, char *file, char *ID, char *psw) {char *p, *q;if ((p = strtok(packet, " \r")) == NULL)return 0;if (strcmp(p, "GET") == 0) { //GETif ((p = strtok(NULL, " \r")) == NULL)return 1;q = p;if ((p = strtok(NULL, " \r")) != NULL && strcmp(p, "HTTP/1.1") == 0) { //协议HTTP/1.1if ((q = strtok(q, "?")) != NULL) {strcpy(file, q); //文件名if ((q = strtok(NULL, "?")) != NULL) {char *tmp;if ((tmp = strtok(q, "&")) != NULL) {strcpy(ID, tmp + 3);}if ((tmp = strtok(NULL, "&")) != NULL) {strcpy(psw, tmp + 3);}return 2;}}return 1;} elseprintf("未知的协议！\n");} elseprintf("未知的请求！\n");return 0;
}
int headerBuilder(char *msg, int status, int size) {char num[5];char *wday[] = { "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" };char *wmon[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug","Sep", "Oct", "Nov", "Dec" };struct tm *ptr;time_t it;time(&it);ptr = localtime(&it); //取得本地时间switch (status) {case 200://状态行strcat(msg, "HTTP/1.1 200 OK\r\n");//首部strcat(msg, "Date: ");strcat(msg, wday[ptr->tm_wday]);strcat(msg, ", ");sprintf(num, "%d", ptr->tm_mday);strcat(msg, num);strcat(msg, " ");strcat(msg, wmon[ptr->tm_mon]);strcat(msg, " ");sprintf(num, "%d", 1900 + ptr->tm_year);strcat(msg, num);strcat(msg, " ");sprintf(num, "%d", ptr->tm_hour);strcat(msg, num);strcat(msg, ":");sprintf(num, "%d", ptr->tm_min);strcat(msg, num);strcat(msg, ":");sprintf(num, "%d", ptr->tm_sec);strcat(msg, num);strcat(msg, " GMT\r\n");strcat(msg, "Content-Type: text/html;charset=utf-8\r\n");strcat(msg, "Content-Length: ");sprintf(num, "%d", size);strcat(msg, num);strcat(msg, "\r\n\r\n");break;case 404://状态行strcat(msg, "HTTP/1.1 404 Not Found\r\n");//首部strcat(msg, "Date: ");strcat(msg, wday[ptr->tm_wday]);strcat(msg, ", ");sprintf(num, "%d", ptr->tm_mday);strcat(msg, num);strcat(msg, " ");strcat(msg, wmon[ptr->tm_mon]);strcat(msg, " ");sprintf(num, "%d", 1900 + ptr->tm_year);strcat(msg, num);strcat(msg, " ");sprintf(num, "%d", ptr->tm_hour);strcat(msg, num);strcat(msg, ":");sprintf(num, "%d", ptr->tm_min);strcat(msg, num);strcat(msg, ":");sprintf(num, "%d", ptr->tm_sec);strcat(msg, num);strcat(msg, " GMT\r\n\r\n");break;}return 0;
}
bool check(char *ID, char *psw) {printf("check info %s %s\n", ID, psw);int cfd = socket(AF_INET, SOCK_STREAM, 0);int recbytes;char buffer[50] = { '\0' };struct sockaddr_in s_add;if (-1 == cfd) {printf("socket fail ! \r\n");return 0;}bzero(&s_add, sizeof(struct sockaddr_in));s_add.sin_family = AF_INET;s_add.sin_addr.s_addr = inet_addr("127.0.0.1");s_add.sin_port = htons(8083);if (connect(cfd, (struct sockaddr *) (&s_add), sizeof(s_add)) == -1) {printf("connect fail !\r\n");return 0;}printf("connect ok !\r\n");strcpy(buffer, "login");printf("sending %s\n", buffer);if ((recbytes = send(cfd, buffer, 5, 0)) == -1) {return 0;}strcpy(buffer, ID);buffer[strlen(ID)] = '\0';printf("sending %s\n", buffer);if ((recbytes = send(cfd, buffer, strlen(ID), 0)) == -1) {return 0;}strcpy(buffer, psw);buffer[strlen(psw)] = '\0';printf("sending %s\n", buffer);if ((recbytes = send(cfd, buffer, strlen(psw), 0)) == -1) {return 0;}if (-1 == (recbytes = recv(cfd, buffer, 3, 0))) {return 0;}close(cfd);printf("receive %s\n", buffer);if (strcmp(buffer, "YES"))return 1;return 0;
}int main() {int sockfd, client_fd;struct sockaddr_in my_addr;struct sockaddr_in remote_addr;char msg[MAXN] = { '\0' };//创建套接字if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {perror("socket create failed!");exit(1);}my_addr.sin_family = AF_INET; //通信类型my_addr.sin_port = htons(3334); //端口my_addr.sin_addr.s_addr = INADDR_ANY; //本地地址bzero(&(my_addr.sin_zero), 8);//绑定端口地址if (bind(sockfd, (struct sockaddr*) &my_addr, sizeof(struct sockaddr))== -1) {exit(1);}//开始监听if (listen(sockfd, 10) == -1) {exit(1);}while (1) {socklen_t sin_size = sizeof(struct sockaddr_in);if ((client_fd = accept(sockfd, (struct sockaddr*) &remote_addr,&sin_size)) == -1) {break;}printf("收到%s的报文\n", (char*) inet_ntoa(remote_addr.sin_addr));//子进程段if (!fork()) {char buf[MAXN];char file[50] = { '\0' };char path[100] = "/Users/pcforsong/ksacm"; //服务器文件的路径//读报文if (read(client_fd, buf, MAXN) < 0) {perror("reading stream error!");continue;}// printf("%s\n", buf);
FILE *fp;char ID[50] = { '\0' }, psw[50] = { '\0' };bool checked = false;int OP = analysis_packet(buf, file, ID, psw);if (OP) { //get//生成本地文件路径
                strcat(path, file);printf("path: %s\n", path);printf("info: %s %s\n", ID, psw);if (!checked && OP == 2 && !check(ID, psw))exit(0);checked = 1;if ((fp = fopen(path, "r")) != NULL) { //找到文件//通过文件指针计算文件大小fseek(fp, 0, SEEK_END); //到文件结尾int size = ftell(fp); //与文件首偏移字节数fseek(fp, 0, SEEK_SET); //移回开头//填写msg添加200响应报文头headerBuilder(msg, 200, size);while (fgets(buf, 2048, fp) != NULL) {strcat(msg, buf);};fclose(fp);} else {//为msg添加404响应报文头headerBuilder(msg, 404, 0);}//向client发送应答报文msg// printf("%s\n", msg);if (send(client_fd, msg, strlen(msg), 0) == -1)perror("send error!");close(client_fd);} elseprintf("报文解析失败！\n");exit(0);}close(client_fd);}return 0;
}

new Thread(new Runnable(){public void run(){} // 重载Thread中Runnable target的run方法
}) {public void run(){} //子类重载继承自父类的run方法
}

import java.io.*;
import java.net.*;
import java.sql.*;
import java.util.Vector;class ServerThread implements Runnable {private Socket socket;// 定义套接口private BufferedReader in;// 定义输入流private PrintWriter out;// 定义输出流
    Connection conn;int no;public ServerThread(Socket s) throws IOException {// 线程构造函数socket = s;// 取得传递参数in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 创建输入流out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);// 创建输出流
    }public void run() {// 重写run方法System.out.println("监听Socket中...");try {Class.forName("com.mysql.jdbc.Driver");// 连接数据库conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/javaicq", "root", "");while (true) {String OP = in.readLine();// 停止if (OP.equals("end"))break;// 登录else if (OP.equals("login")) {try {PreparedStatement prepare = conn.prepareStatement("select nickname,password from icq where icqno=?");// 设定数据库查寻条件int g = Integer.parseInt(in.readLine());String passwd = in.readLine().trim();prepare.setInt(1, g);// 设定参数ResultSet rs = prepare.executeQuery();// 执行数据库查寻if (!rs.next())out.println("用户不存在");else {// 以下比较输入的号码于密码是否相同String pass = rs.getString("password").trim();if (!passwd.equals(pass)) {out.println("密码错误");} else {// 以及注册用户的ip 地址PreparedStatement online = conn.prepareStatement("update icq set ip=? where icqno=?");online.setString(1, socket.getInetAddress().getHostAddress());online.setInt(2, g);online.executeUpdate();// set status onlinePreparedStatement status = conn.prepareStatement("update icq set status=1 where icqno=?");status.setInt(1, g);status.executeUpdate();out.println("YES");}}rs.close();} catch (Exception e) {e.printStackTrace();out.println("Error");}}// 新建else if (OP.equals("new")) {try {// 准备接受用户的呢称，密码，email，个人资料，籍贯，头像等信息String nickname = in.readLine().trim();String password = in.readLine().trim();String email = in.readLine().trim();String info = in.readLine().trim();String place = in.readLine().trim();int picindex = Integer.parseInt(in.readLine());PreparedStatement userInfo = conn.prepareStatement("insert into icq(nickname,password,email,info,place,pic,icqno) values(?,?,?,?,?,?,?)");userInfo.setString(1, nickname);userInfo.setString(2, password);userInfo.setString(3, email);userInfo.setString(4, info);userInfo.setString(5, place);userInfo.setInt(6, picindex);userInfo.setInt(7, Integer.parseInt(Double.toString(Math.random()).substring(3, 8)));userInfo.executeUpdate();// 执行数据库添加// 查询其注册的号码PreparedStatement qNo = conn.prepareStatement("select icqno from icq where nickname=?");qNo.setString(1, nickname);ResultSet rs = qNo.executeQuery();while (rs.next()) { // 找到最近注册的号码no = rs.getInt(1);}out.println("YES");out.println(no);rs.close();} catch (Exception e) {e.printStackTrace();out.println("Error");}}}} catch (IOException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();} finally {try {conn.close();socket.close();} catch (IOException e) {} catch (SQLException e) {}}}
}public class Server {// 主服务器类public static void main(String args[]) throws IOException {ServerSocket so = new ServerSocket(8081);// 在8081端口创建套接口so.setSoTimeout(100000);System.out.println("服务器已启动 " + so);Socket testServer = new Socket(InetAddress.getLocalHost(), 8081);PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(testServer.getOutputStream())), true);try {while (true) {Socket socket = so.accept();// 无限监听客户的请求System.out.println("建立Socket连接:" + socket);try {
//                    out.println("login");
//                    out.println(123);
//                    out.println(123);ServerThread st = new ServerThread(socket);// 创建新线程处理Socketnew Thread(st).start(); } catch (IOException e) {socket.close();}}} catch (SocketTimeoutException e) {System.out.println("超时断开连接");} finally {so.close();}}
}

View Code

// 创建UDP Socket
try {DatagramSocket sendSocket = new DatagramSocket();DatagramSocket receiveSocket = new DatagramSocket(udpPORT);System.out.println("创建UDP数据报成功");} catch (SocketException se) {se.printStackTrace();System.out.println("创建UDP数据报失败");}
// 接收数据报byte array[] = new byte[512];for (int x = 0; x < 512; x++)array[x] = ' ';DatagramPacket  receivePacket = new DatagramPacket(array, array.length);receiveSocket.receive(receivePacket);byte[] data = receivePacket.getData();String infofromip = receivePacket.getAddress().getHostAddress().toString().trim();received = new String(data, 0, data.length);
// 发送数据报
String info = "offline";byte[] data = info.getBytes();sendPacket = new DatagramPacket(data, s.length(),InetAddress.getByName(whoaddmesip.get(i).toString()),sendPort);sendSocket.send(sendPacket);

1. GET /chat HTTP/1.1
2. Host: server.example.com
3. Upgrade: websocket
4. Connection: Upgrade
5. Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
6. Origin: http://example.com
7. Sec-WebSocket-Protocol: chat, superchat
8. Sec-WebSocket-Version: 13

1. HTTP/1.1 101 Switching Protocols
2. Upgrade: websocket
3. Connection: Upgrade
4. Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=
5. Sec-WebSocket-Protocol: chat

　　wss-URI = "wss:" "//" host [ ":" port ] path [ "?" query ]

package com.ibcio;import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServletRequest;import org.apache.catalina.websocket.StreamInbound;@WebServlet(urlPatterns = { "/message" })
// 如果要接收浏览器的ws://协议的请求就必须实现WebSocketServlet这个类
public class WebSocketMessageServlet extendsorg.apache.catalina.websocket.WebSocketServlet {private static final long serialVersionUID = 1L;public static int ONLINE_USER_COUNT = 1;public String getUser(HttpServletRequest request) {return (String) request.getSession().getAttribute("user");}// 跟平常Servlet不同的是，需要实现createWebSocketInbound，在这里初始化自定义的WebSocket连接对象
    @Overrideprotected StreamInbound createWebSocketInbound(String subProtocol,HttpServletRequest request) {return new WebSocketMessageInbound(this.getUser(request));}
}

var websocket;//初始话WebSocketfunction initWebSocket() {if (window.WebSocket) {websocket = new WebSocket(encodeURI('ws://localhost:8080/WebSocket/message'));websocket.onopen = function() {//连接成功win.setTitle(title + '  (已连接)');}websocket.onerror = function() {//连接失败win.setTitle(title + '  (连接发生错误)');}websocket.onclose = function() {//连接断开win.setTitle(title + '  (已经断开连接)');}//消息接收websocket.onmessage = function(message) {var message = JSON.parse(message.data);//接收用户发送的消息if (message.type == 'message') {output.receive(message);} else if (message.type == 'get_online_user') {//获取在线用户列表var root = onlineUser.getRootNode();} else if (message.type == 'user_join') {//用户上线var root = onlineUser.getRootNode();var user = message.user;var node = root.createNode({id : user,text : user,iconCls : 'user',leaf : true});root.appendChild(node);} else if (message.type == 'user_leave') {//用户下线var root = onlineUser.getRootNode();var user = message.user;var node = root.findChild('id',user);root.removeChild(node);}}}};//发送消息function send() {var message = {};if (websocket != null) {if (input.getValue()) {Ext.apply(message, {from : user,content : input.getValue(),timestamp : new Date().getTime(),type : 'message'});websocket.send(JSON.stringify(message));//output.receive(message);input.setValue('');}} else {Ext.Msg.alert('提示', '您已经掉线，无法发送消息!');}}});

View Code

//建立基于UDP的Socket连接
-(void)openUDPServer{//初始化udpAsyncUdpSocket *tempSocket=[[AsyncUdpSocket alloc] initWithDelegate:self];self.udpSocket=tempSocket;[tempSocket release];//绑定端口NSError *error = nil;[self.udpSocket bindToPort:4333 error:&error];//发送广播设置[self.udpSocket enableBroadcast:YES error:&error];//加入群里，能接收到群里其他客户端的消息[self.udpSocket joinMulticastGroup:@"127.0.0.1" error:&error];//启动接收线程[self.udpSocket receiveWithTimeout:-1 tag:0];
}//通过UDP,发送消息
-(void)sendMassage:(NSString *)message
{   NSDate *nowTime = [NSDate date];NSMutableString *sendString=[NSMutableString stringWithCapacity:100];[sendString appendString:message];//开始发送BOOL res = [self.udpSocket sendData:[sendString dataUsingEncoding:NSUTF8StringEncoding] toHost:@"127.0.0.1"port:4333 withTimeout:-1 tag:0];if (!res) {UIAlertView *alert = [[UIAlertView alloc] initWithTitle:@"提示"message:@"发送失败"delegate:selfcancelButtonTitle:@"取消"otherButtonTitles:nil];[alert show];[alert release];}
}

#pragma mark UDP Delegate Methods
- (BOOL)onUdpSocket:(AsyncUdpSocket *)sock didReceiveData:(NSData *)data withTag:(long)tag fromHost:(NSString *)host port:(UInt16)port
{   [self.udpSocket receiveWithTimeout:-1 tag:0];NSLog(@"host---->%@",host);//接收到数据回调

　　　 NSString *info=[[[NSString alloc] initWithData:data encoding: NSUTF8StringEncoding] autorelease];

    return YES;
}- (void)onUdpSocket:(AsyncUdpSocket *)sock didNotSendDataWithTag:(long)tag dueToError:(NSError *)error
{//无法发送时,返回的异常提示信息
}
- (void)onUdpSocket:(AsyncUdpSocket *)sock didNotReceiveDataWithTag:(long)tag dueToError:(NSError *)error
{   //无法接收时，返回异常提示信息
}