jdk1.4 构建 java多线程,并发设计框架使用列子(六)-白红宇

jdk1.4 构建 java多线程,并发设计框架使用列子(六)

阅读量：2794 次

发布时间：2019-05-13

本文共 2818 字，大约阅读时间需要 9 分钟。

java 多线程,,Socket,网络,流,并发,框架，已经讲完。

一个客户端实现的代码：

import java.io.*;
import java.nio.ByteBuffer;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.willfar.commons.net.ConcurrentQueue;
import com.willfar.commons.net.IProcessClientData;
import com.willfar.shantou.engine.protocol.ScadaIfcValidate;
/**
 * 处理客户端的服务请求,ClientStream
 * ByteArrayOutputStream
 * @author guishuanglin 2008-11-3
 * 
 */
public class ProcessClientDataImpl implements
        IProcessClientData { 
    private Log logger = LogFactory.getLog(ProcessClientDataImpl.class);
    //ByteArrayOutputStream
    private ConcurrentQueue dataQueue;
    private ByteArrayOutputStream streamData;
    private ByteArrayOutputStream tempStream;
    private ByteBuffer buf;
    private int requestCount;
    private String netAddress;
    private ScadaIfcValidate sv;
publicvoid run() { 
try { 
            String s = "";
            boolean bool = true;
            sv = new ScadaIfcValidate();
            tempStream = new ByteArrayOutputStream();
while (bool) { 
                streamData = (ByteArrayOutputStream)dataQueue.deQueue();
if (streamData != null) { 
                    int ll = streamData.size();
if (ll == 3) { 
                        s = streamData.toString();
if ("end".equals(s)) { 
                            logger.info("[" + requestCount + "],客户端发送数据结束.");
                            bool = false;
                            continue;
                        }
                    }
                    //数据太短，暂时保存
                    streamData.writeTo(tempStream);
                    ll = tempStream.size();
if (ll < 3){ 
                        continue;
                    }
                    byte[] b = tempStream.toByteArray();
                    //验证数据是否完整,正确.
                    boolean bol = sv.isValid(b);
if (bol) { 
                        logger.info("[" + requestCount + "],收到客户端[" 
                                + netAddress+ "]数据,长度: " + tempStream.size() 
                                + " 字节,Fn内容：["+ sv.getFn() + "]");
                        new Thread(new ProcessAcceptData(b)).start();
                    }else{ 
                        //数据长度不够，等下一包数据
if(sv.getRemaining()>0){ 
                            logger.info("数据总长: "+sv.getAllLength()+" 字节,收到: "
                                    + sv.getCurLength()+" 字节,等下一包数据...");
                            continue;
                        }else{ 
                            logger.info("[" + requestCount + "],收到客户端[" + netAddress
                                    + "]数据,长度: " + tempStream.size() + " 字节,内容：[数据不完整]");
                            //无用数据清除
                            this.getStringByByte(tempStream);
                            tempStream.reset();
                            tempStream.close();
                            
                        }
                    }               
try { 
                        streamData.reset();
                        streamData.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
            }
        } catch (IOException e1) { 
            e1.printStackTrace();
        } finally { 
try { 
                dataQueue.clear();
                dataQueue = null;
                tempStream.reset();
                tempStream.close();
                tempStream= null;
                streamData.reset();
                streamData.close();
                streamData=null;
                logger = null;
                sv =null;
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    }
    //ConcurrentQueue<ByteArrayOutputStream>
publicvoid ProcessStreamData(ConcurrentQueue dataQueue, int requestCount, String netAddress) { 
        this.dataQueue = dataQueue;
        this.requestCount = requestCount;
        this.netAddress = netAddress;
    }
    
publicvoid getStringByByte(ByteArrayOutputStream tempStream){ 
        //输出内容
if(tempStream!=null){ 
            StringBuffer bf = new StringBuffer();
            byte[] b = tempStream.toByteArray();
for(int i=0;i<b.length;i++){ 
                bf.append(b[i]);
            }
            logger.info(bf.toString());
            bf = null;
            b  = null;
        }
    }
}