| Android 开发即时聊天工具 YQ :(一) Socket 初步
					当前位置:点晴教程→知识管理交流
					
					→『 技术文档交流 』
					
				 
 这段时间在学习Android网络编程,习惯一边写个简单的项目一边学习,所以就有了这个简易的简易的,,,项目,类似于手机QQ等等的即时聊天工具,当然功能及其简单,跟那些没法比,只是学习,实现简单功能就OK,听说QQ是有自己的协议的,貌似挺复杂,,,只为学习交流之用,而且本人也是Android小菜鸟一枚,错误或不足在所难免,请大家多多指正,3Q~ 
 先看看socket通信基础: 所谓socket通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。 Socket和ServerSocket类库位于java.net包中。ServerSocket用于服务器端,Socket是建立网络连接时使用的。在连接成功时,应用程序两端都会产生一个Socket实例,操作这个实例,完成所需的会话。 服务器: 使用ServerSocket监听指定的端口,等待客户连接请求,客户连接后,会话产生;在完成会话后,关闭连接。  使用Socket对网络上某一个服务器的某一个端口发出连接请求,一旦连接成功,打开会话;会话完成后,关闭Socket。 
 0~1023的端口号为系统所保留,例如http服务的端口号为80,telnet服务的端口号为21,ftp服务的端口号为23, 所以我们在选择端口号时,最好选择一个大于1023的数以防止发生冲突。 
 简单的Client/Server示例: 服务器: 
 [java]  
 public class Client {
 public static void main(String[] args) throws Exception {
  //向本机的5469端口发出客户请求
  Socket socket=new Socket(InetAddress.getLocalHost(),5469);
  //由Socket对象得到输入流,并构造相应的BufferedReader对象
  BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
  //由Socket对象得到输出流,并构造PrintWriter对象
  PrintWriter os=new PrintWriter(socket.getOutputStream());
  //由系统标准输入设备构造BufferedReader对象
  BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
  while(true){
   String str=sin.readLine();//从系统标准输入读入一字符串
   os.println(str);
   os.flush(); //刷新输出流,使Server马上收到该字符串
   
   String s=is.readLine();
   System.out.println("Server : "+s);//在标准输出上打印从Server读入的字符串
   if(str.equals("end")){
    break;
   }
  }
  is.close();//关闭Socket输入流
  os.close();//关闭Socket输出流
  socket.close();//关闭Socket
 }
}
客户端: 
 [java]  
 public class MyServer {
 public static void main(String[] args) throws Exception{
  ServerSocket server=new ServerSocket(5469);//创建一个ServerSocket在端口5469监听客户请求
  Socket client=server.accept();//使用accept()阻塞等待客户请求
  BufferedReader is=new BufferedReader(new InputStreamReader(client.getInputStream()));
  PrintWriter os=new PrintWriter(client.getOutputStream());
  BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
  while(true){
   String str=is.readLine();
   System.out.println("Client : "+str);//在标准输出上打印从Client读入的字符串
   
   os.println(sin.readLine());
   os.flush();//刷新输出流,使Client马上收到该字符串
   if(str.equals("end")){
    break;
   }
  }
  is.close();
  os.close();
  client.close();
  server.close();
 }
}回话示例图: 
 上边的代码只是实现一个客户端访问服务器,如果要多个客户同时访问一个服务器,那么服务端的代码就要修改了: 
 [java]  
 public class MyServer extends Thread{
 Socket client;
 public MyServer(Socket c){
  this.client=c;
 }
 public void run() {
  try{
   BufferedReader is=new BufferedReader(new InputStreamReader(client.getInputStream()));
   PrintWriter os=new PrintWriter(client.getOutputStream());
   BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
   while(true){
    String s=is.readLine();
    System.out.println("Client : "+s);//在标准输出上打印从Client读入的字符串
    
    String str=sin.readLine();//从系统标准输入读入一字符串
    os.println(str);
    os.flush();//刷新输出流,使Client马上收到该字符串
    if(str.equals("end")){
     break;
    }
   }
   is.close();
   os.close();
   client.close();
  }catch(Exception e){
   e.printStackTrace();
  }
 }
 public static void main(String[] args) throws Exception{
  ServerSocket server=new ServerSocket(5469);//创建一个ServerSocket在端口5469监听客户请求
  while(true){
   MyServer s=new MyServer(server.accept());//使用accept()阻塞等待客户请求
   s.start();
  }
 }
}该文章在 2013/2/25 14:15:02 编辑过 | 关键字查询 相关文章 正在查询... |