pcwiki的部落格

1
2
3
4
5
6

  <servlet>
    <servlet-name>socketservlet</servlet-name>
    <servlet-class>com.bluepure.SocketServlet</servlet-class>
    <load-on-startup>1</load-on-startup>
  </servlet>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

package com.bluepure;
 
import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
 
public class SocketServlet extends HttpServlet {
    Myserver myserver = null;
    public void init() throws ServletException {
        super.init();
        myserver = new Myserver();
        myserver.startServer();
        System.out.println("启动Socket server");
    }
 
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws
            ServletException, IOException {
        PrintWriter out = response.getWriter();
        out.println("nothing");
        out.close();
    }
 
    public void destroy() {
        super.destroy();
 
        System.out.println("关闭Socket server");
        if (myserver != null) {
            myserver.stopServer();
        }
    }
}
 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

package com.bluepure;
 
import java.net.*;
import java.io.*;
 
public class Myserver extends Thread {
    private boolean started = false;
    private int port = 3333;
    public Myserver() {
    }
 
    public void run() {
        try {
            ServerSocket server = new ServerSocket(port);
            while (started) {
                final Socket socket = server.accept();
                new Thread() {
                    public void run() {
                        try {
                            InputStream is = socket.getInputStream();
                            OutputStream os = socket.getOutputStream();
                            java.io.BufferedReader bis = new BufferedReader(new
                                    InputStreamReader(is, "UTF-8"));
                            String s = null;
                            while ((s = bis.readLine()) != null) {
                                System.out.println("s==" + s);
//将客户端输入的内容变成大写再写回
                                os.write(("uppercase is : " + s + "\r\n").
                                         toUpperCase().
                                         getBytes());
//如果是退出指令,则关闭Socket
                                if ("quit".equalsIgnoreCase(s)) {
                                    os.write("BYE\r\n".getBytes());
                                    bis.close();
                                    os.close();
                                    socket.close();
                                    break;
                                }
                            }
 
                        } catch (Exception ex) {
                            ex.printStackTrace();
                        }
                    }
                }.start();
 
            }
            server.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
 
    }
 
    public void startServer() {
        started = true;
        this.start();
    }
 
    public void stopServer() {
        started = false; ;
    }
 
}