Java

本类阅读TOP10

·使用MyEclipse开发Struts框架的Hello World!(录像1)
·hibernate配置笔记
·AOP编程入门--Java篇
·linux下Tomcat 5.0.20 与 Apache 2 安装/集成/配置
·在win2003下整合了整合Tomcat5.5+ apache_2.0.53+ mod_jk_2.0.47.dll
·构建Linux下IDE环境--Eclipse篇
·Jsp 连接 mySQL、Oracle 数据库备忘(Windows平台)
·ASP、JSP、PHP 三种技术比较
·Tomcat5.5.9的安装配置
·AWT GUI 设计笔记(二)

分类导航
VC语言Delphi
VB语言ASP
PerlJava
Script数据库
其他语言游戏开发
文件格式网站制作
软件工程.NET开发
用Socket建立个最简单的聊天程序

作者:未知 来源:月光软件站 加入时间:2005-5-13 月光软件站

用Socket建立个最简单的聊天程序

Java、Socket、网络编程、聊天

/*一个作为Server*/
import java.io.*;
import java.net.*;
public class MyServer{
 public static void main(String[] args)
      throws IOException{
  ServerSocket s=new ServerSocket(8658);
  System.out.println("开始:"+s);
  try{
   Socket socket=s.accept();
   try{
    System.out.println("连接接受"+socket);
    BufferedReader in=new BufferedReader(new InputStreamReader
      (socket.getInputStream()));
    PrintWriter out=new PrintWriter(new BufferedWriter(
     new OutputStreamWriter(socket.getOutputStream())),true);
    while(true){
     String str=in.readLine();
     if(str.equals("q")) break;
     System.out.println("对方说:"+str);
     BufferedReader is=new BufferedReader(new InputStreamReader(System.in));
     String input=new String();
     input=is.readLine().trim();
     out.println(input);
     System.out.print("我说:");
     out.flush();
    }
   }
   finally{
    System.out.println("关闭....");
    socket.close();
   }
  }
  finally{
   s.close();
  }
 }
}

/*一个作为Client*/
import java.io.*;
import java.net.*;
public class MyClient{
 public static void main(String[] args)
   throws IOException{
  InetAddress addr=InetAddress.getByName("127.0.0.1");
  System.out.println("地址="+addr);
  Socket socket=new Socket(addr,8658);
  try{
   System.out.println("socket="+socket);
   BufferedReader is=new BufferedReader(new InputStreamReader(System.in));
    PrintWriter out=new PrintWriter(socket.getOutputStream(),true);
   for(;;){
    System.out.print("我说:");
    String input=new String();
    input=is.readLine().trim();
    out.println(input);
    if(input.equals("q")) break;
    BufferedReader in=new BufferedReader(new InputStreamReader
        (socket.getInputStream()));
     String str=in.readLine();
    System.out.println("对方说:"+str);
    out.flush();
   }

  }
  finally{
   System.out.println("关闭");
   socket.close();
  }
 }
}




相关文章

相关软件