黑马程序员技术交流社区

标题: TCP协议服务端ServerScoket接收客户端并发请求。 [打印本页]

---

作者: 谭景宾    时间: 2012-5-5 20:10
标题: TCP协议服务端ServerScoket接收客户端并发请求。
想让服务端处理多个客户端的请求，最好将每个客户端封装到单独的线程中。
只要明确客户端要执行的服务端代码即可，这些代码放入run方法中。

//定义线程
class picThread implements Runnable
{
        private Socket s;
        picThread(Socket s){
                this.s=s;
        }
        public vodi run(){
                try{
                        inputStream in = s.getInputStream();
       
                        FileOutputStream os = new FileOutputStrem("conten.txt");

                        byte[] but = new byte[1024];
                        String len = null;
                        while((len=in.readLine(but))!=-1){
                                os.write(data,0,len);
                        }
                        os.close();
                        s.close();       
                }catch(Exception e){
                        theow new RuntimeException("失败");
                }
        }
}

//服务端，循环获取客户端，并循环建立线程
class picServer{
        public static void main(String[] args)throws Exception{

                ServerScoket service = new SercerSocket(端口);

                while(true){
                        Socket s = ss.sccept();
                        new Thread(new PicThread(s)).start();
                }
        }
       
}
这样，当a客户访问服务端的时候会new一个线程给a客户执行，b客户进来时，又new一个线程给b客户执行
这样就成功实现了客户端并发请求。

---

作者: 徐慧书    时间: 2012-5-5 20:28
楼主啊，         String len = null; 这是啥意思呢？ 然后你又     while((len=in.readLine(but))!=-1){
len 应该是整形， int len = 0 ；吧！ 而且in.readLine() 也没有这个方法啊，readLine()是BufferedReader类的方法吧。
   public vodi run(){    是void不是vodi   。。。

---

作者: 谭景宾    时间: 2012-5-5 20:33

徐慧书 发表于 2012-5-5 20:28
楼主啊，         String len = null; 这是啥意思呢？ 然后你又     while((len=in.readLine(but))!=-1){
l ...

阁下真厉害，手写的，些错了，不好意思
应该是
int len = 0;
while((len=in.read(but))!=-1){
       os.write(data,0,len);
}

---

作者: 云惟桉    时间: 2012-5-5 20:35
嗯，但是访问量过多也会引起问题。
同时访问量过多会使得服务器大部分资源得不到释放，造成负载过大甚至崩溃。
DDoS攻击利用的就是这一个原理。说起来算是一个隐蔽的漏洞，别人可以利用访问过载使得别的客户端无法访问，形成对服务器的恶意攻击。
因此为了安全，应该在ServerSocket初始化的时候限制访问队列的长度，使得访问数量有限。

个人理解而已，希望能补充楼主的设计思想。有错也请指出，互相学习。

---

作者: 谭景宾    时间: 2012-5-5 20:38
大家来找茬，帮忙找找，还有木有写错的地方。
谢啦。。。
就当锻炼自己的能力吧，嘻嘻！！！

---

作者: 徐慧书    时间: 2012-5-5 20:44

谭景宾 发表于 2012-5-5 20:38
大家来找茬，帮忙找找，还有木有写错的地方。
谢啦。。。
就当锻炼自己的能力吧，嘻嘻！！！ ...

哥们，够呛复制到Eclipse中，太多错误了，，您可以继续慢慢找找

---

作者: 谭景宾    时间: 2012-5-5 20:49

徐慧书 发表于 2012-5-5 20:44
哥们，够呛复制到Eclipse中，太多错误了，，您可以继续慢慢找找

好吧，多想哥们。

---

作者: 云惟桉    时间: 2012-5-5 20:56

谭景宾 发表于 2012-5-5 20:38
大家来找茬，帮忙找找，还有木有写错的地方。
谢啦。。。
就当锻炼自己的能力吧，嘻嘻！！！ ...

编程的错误，希望是自己找比较好，只有自己知道自己曾经怎么犯错，才有利于下一次更好的修正。
希望楼主好好修炼，终成正果进入黑马，呵呵

---

作者: 谭景宾    时间: 2012-5-5 20:56
更正下代码...已经找错误了。
import java.net.*;
import java.util.*;
import java.io.*;
class picThread implements Runnable
{
        private Socket s;
        picThread(Socket s){
                this.s=s;
        }
        public void run(){
                try{
                        InputStream in = s.getInputStream();
       
                        FileOutputStream os = new FileOutputStream("conten.txt");

                        byte[] but = new byte[1024];
                        int len = 0;
                        while((len=in.read(but))!=-1){
                                os.write(but,0,len);
                        }
                        os.close();
                        s.close();       
                }catch(Exception e){
                        throw new RuntimeException("失败");
                }
        }
}

//服务端，循环获取客户端，并循环建立线程
class picServer{
        public static void main(String[] args)throws Exception{

                ServerSocket service = new ServerSocket(10001);

                while(true){
                        Socket s = service.accept();
                        new Thread(new picThread(s)).start();
                }
        }
       
}

---

作者: 谭景宾    时间: 2012-5-5 21:04

云惟桉 发表于 2012-5-5 20:35
嗯，但是访问量过多也会引起问题。
同时访问量过多会使得服务器大部分资源得不到释放，造成负载过大甚至崩 ...

嗯嗯，多谢兄台了。

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2