JAVA------9.JavaWeb自启动线程，并加入socket编程

package com.caipei.thread;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Random;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;




public class MyListener implements ServletContextListener{

    private MyThread myThread; 71 
    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        // TODO Auto-generated method stub
        String str=null;
        if (str==null&&myThread==null) {
            myThread=new MyThread();
            myThread.start();//servlet 上下文初始化时启动socket
        }
    }


    //自定义一个class 线程类继承自线程类 重写 
    class MyThread extends Thread
    {

        public static final int PORT = 4800;//监听的端口号     
        public void run()
        {
            while(!this.isInterrupted())
            {
                try {
                    Thread.sleep(2000);//每隔2000ms执行一次
                } catch (Exception e) {
                    // TODO: handle exception
                    e.printStackTrace();
                }


                //定义一个ServerSocket监听在端口4800上  
                ServerSocket server = null;
                try {
                    server = new ServerSocket(PORT);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }  
                while (true) {  
                    //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的  
                    Socket socket = null;
                    try {
                        socket = server.accept();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }  
                    //每接收到一个Socket就建立一个新的线程来处理它  

                    new Thread(new Task(socket)).start();  
                }  
            }

        }


        /** 
         * 用来处理Socket请求的 
         */  
        class Task implements Runnable {  

            private Socket socket;  

            public Task(Socket socket) {  
                this.socket = socket;  
            }  

            public void run() {  
                try {  
                    handleSocket();  
                } catch (Exception e) {  
                    e.printStackTrace();  
                }  
            }  

            /** 
             * 跟客户端Socket进行通信 
             * @throws Exception 
             */  
            public void handleSocket() throws Exception {  
                BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
                StringBuilder sb = new StringBuilder();  
                String temp;  
                int index;  
                int flag=1;
                while ((temp=br.readLine()) != null) {  
                    System.out.println(temp);  
                    if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收  
                        sb.append(temp.substring(0, index));  
                        break;  
                    }  
                    sb.append(temp);  
                }  

加入jar包

在web.xml里加入配置文件

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
  <display-name>JavaWebThread</display-name>
  <welcome-file-list>
    <welcome-file>index.html</welcome-file>
    <welcome-file>index.htm</welcome-file>
    <welcome-file>index.jsp</welcome-file>
    <welcome-file>default.html</welcome-file>
    <welcome-file>default.htm</welcome-file>
    <welcome-file>default.jsp</welcome-file>
  </welcome-file-list>
  
  <listener>
  <listener-class> com.caipei.thread.MyListener</listener-class>
 </listener>
  
</web-app>