中国IT动力,最新最全的IT技术教程
最新100篇 | 推荐100篇 | 专题100篇 | 排行榜 | 搜索 | 在线API文档 | 网通镜像
首 页 | 程序开发 | 操作系统 | 软件应用 | 图形图象 | 网络应用 | 精文荟萃 | 教育认证 | 硬件维护 | 未整理篇 | 站长教程
ASP JS PHP工程 ASP.NET 网站建设 UML J2EESUN .NET VC VB VFP 网络维护 数据库 DB2 SQL2000 Oracle Mysql
服务器 Win2000 Office C DreamWeaver FireWorks Flash PhotoShop 上网宝典 CorelDraw 协议大全 网络安全 微软认证
硬件维护  CPU  主板  硬盘  内存  显卡  显示器  键盘鼠标  声卡音箱  打印机  机箱电源  BIOS  网卡  C#  Java  Delphi  vs.net2005
  当前位置:> 程序开发 > 编程语言 > Java > 基础 > Java语言基础
Java基础 三步学会Java Socket编程(二)
作者:dxaw 时间:2007-06-14 21:03 出处:ccidnet.com 责编:月夜寒箫
              摘要:Java基础 三步学会Java Socket编程(二)

第二步 多个客户同时连接

在实际的网络环境里,同一时间只对一个用户服务是不可行的。一个优秀的网络服务程序除了能处理用户的输入信息,还必须能够同时响应多个客户端的连接请求。在java中,实现以上功能特点是非常容易的。

设计原理:

主程序监听一端口,等待客户接入;同时构造一个线程类,准备接管会话。当一个Socket会话产生后,将这个会话交给线程处理,然后主程序继续监听。运用Thread类或Runnable接口来实现是不错的办法。

{实现消息共享}

 

import java.io.*;
            import java.net.*;
            public class Server extends ServerSocket
            {
            private static final int SERVER_PORT = 10000;
            public Server() throws IOException
            {
            super(SERVER_PORT);
            try
            {
            while (true)
            {
            Socket socket = accept();
            new CreateServerThread(socket);
            }
            }
            catch (IOException e)
            {}
            finally
            {
            close();
            }
            }
            //--- CreateServerThread
            class CreateServerThread extends Thread
            {
            private Socket client;
            private BufferedReader in;
            private PrintWriter out;
            public CreateServerThread(Socket s) throws IOException
            {
            client = s;
            in = new BufferedReader(new InputStreamReader(client.getInputStream(), "GB2312"));
            out = new PrintWriter(client.getOutputStream(), true);
            out.println("--- Welcome ---");
            start();
            }
            public void run()
            {
            try
            {
            String line = in.readLine();
            while (!line.equals("bye"))
            {
            String msg = createMessage(line);
            out.println(msg);
            line = in.readLine();
            }
            out.println("--- See you, bye! ---");
            client.close();
            }
            catch (IOException e)
            {}
            }
            private String createMessage(String line)
            {
            xxxxxxxxx;
            }
            }
            public static void main(String[] args) throws IOException
            {
            new Server();
            }
            }

这个程序监听10000端口,并将接入交给CreateServerThread线程运行。CreateServerThread线程接受输入,并将输入回应客户,直到客户输入"bye",线程结束。我们可以在createMessage方法中,对输入进行处理,并产生结果,然后把结果返回给客户。

关闭本页
 
首页 | 投资与合作 | 服务条款 | 隐私政策 | 收藏本站 | 设为首页 | 新用户注册 | 免责声明 | 使用帮助
Copyright ©2005-2008 chinaitpower.com All rights reserved. www.chinaitpower.com 版权所有