一个项目看java TCP/IP Socket编程(1.3版)[转]

前一段时间刚做了个java程序和网络上多台机器的c程序通讯的项目，遵循的是TCP/IP协议，用到了java的Socket编程。网络通讯是java的强项，用TCP/IP协议可以方便的和网络上的其他程序互通消息。 

先来介绍下网络协议： 
    TCP/IP 
        Transmission Control Protocol 传输控制协议 
        Internet Protocol 互联网协议 
    UDP 
        User Datagram Protocol 用户数据协议 

连接协议： 
    分为： 
    面向连接协议: Connection Oriented Protocol 
    非连接协议: Connectionless Protocol 

    1).面向连接协议是指两台电脑在传输数据前，先会建立一个专属的连接。就如电信局的交换机会为打电话双方提供专属连接一样。 
    Internet上的面向连接协议就是TCP/IP 
    特点：确认回应；分组序号；流量控制。 
    TCP/IP属于可靠性传输，适合不容许有传输错误的网络程序设计使用 

    2).非连接协议：无专属连接，无分组，容错，距离短，可同时对多台电脑进行数据传输 
    Internet上的非连接协议就是UDP 

    TCP在网络通信上有极强的生命力，例如远程连接（Telnet）和文件传输（FTP）都需要不定长度的数据被可靠地传输。相比之下UDP操作简单，而且仅需要较少的监护，因此通常用于局域网高可靠性的分散系统中client/server应用程序。 


Socket 是程序与网络间的一种接口，大部分网络应用程序都是点对点的，所谓点就是服务器端和客户端所执行的程序。Socket是用来接收和传送分组的一个端点。 

java的Socket编程要用到java.net包，最常用的是net包下的6个类：InetAddress(互联网协议 (IP) 地址)类，Socket(套接字)类，ServerSocket(套接字服务器)类，DatagramSocket(发送和接收数据报包的套接字)类，DatagramPacket(数据报包)类，MulticastSocket(多播数据报套接字类用于发送和接收 IP 多播包)类，其中InetAddress、Socket、ServerSocket类是属于TCP面向连接协议，DatagramSocket、DatagramPacket和MulticastSocket类则属于UDP非连接协议的传送类。 

本项目因为使用TCP/IP协议，主要用到Socket和ServerSocket类 

项目代码如下 

package com.sse.monitor.serv;

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.BufferedOutputStream;

import java.net.Socket;
import java.net.UnknownHostException;
import java.util.ArrayList;

import com.sse.monitor.bean.Message;
import com.sse.monitor.bean.MessageHead;
import com.sse.monitor.bean.ResponseMessage;
import com.sse.monitor.form.ListenerInvoke;
import com.sse.monitor.form.MainForm;
import com.sse.monitor.util.SwingUtils;

/**
 * Socket套接字工厂，对外接口是静态方法 SocketFactory.request(String, String, String, int)
 * Copyright: Copyright (c) 2008
 * Company: conserv
 * @author cuishen
 * @version 1.3
 */
public class SocketFactory {
    private Socket socket = null;
    private String targetIpAddress = null;
    private int targetPort = 0;
    private static SocketFactory sf = new SocketFactory();

    public SocketFactory() {
    }

    /**
     * 建立一条TCP/IP连接
     * @param targetIpAddress String 目标ip地址
     * @param targetPort String 目标端口
     * @throws IOException
     */
    private void connect(String targetIpAddress, int targetPort) throws IOException {
        setTargetIpAddress(targetIpAddress);
        setTargetPort(targetPort);
        if(socket == null)
            socket = new Socket(targetIpAddress, targetPort);
    }

    /**
     * 这是对外接口。发送命令，接收反馈和接收message放两个线程，
     * 发送命令并接收反馈是短连接，所以每次执行成功后，将销毁socket并终止线程，
     * 接收message是长连接，所以可能会new出n个线程，建议对接收message的线程做缓存
     * @param commandType String 命令类型
     * @param commandContent String 命令内容
     * @param targetIP String 目标ip
     * @param targetPort int 目标端口
     */
    public static void request(String commandType, String commandContent, String targetIP, int targetPort) {
        if (commandType.equalsIgnoreCase(MessageFactory.SCAN_COMMAND)) {
            sf.new GetMessageSocketThread(commandType, commandContent, targetIP, targetPort);
        } else {
            sf.new RequestSocketThread(commandType, commandContent, targetIP, targetPort);
        }
    }

    /**
     * 发送请求
     * @param commandType String 命令类型
     * @param commandContent String 命令内容
     * @param targetIp String 目标ip
     */
    private void sendRequest(String commandType, String commandContent, String targetIp) {
        OutputStream os = null;
        BufferedOutputStream bs = null;
        try {
            os = socket.getOutputStream();
            bs = new BufferedOutputStream(os);
            char[] message = MessageFactory.makeRequestMessage(targetIp, commandType, commandContent, MessageFactory.COMMAND_TRADE_CODE, MessageFactory.RIGHT_COMMAND, MessageFactory.MESSAGE_END_FLAG);
            for (int i = 0; i < message.length; i++)
                bs.write(new String(message).getBytes(), i, 1);
            bs.flush();
            SwingUtils.appendLog(MainForm.jTextArea, "发送请求：'" + commandType + "' '" + commandContent + "' '" + targetIp + "'", ReadConfig.commandStateShowLineCount);
        } catch (IOException e) {
            SwingUtils.appendLog(MainForm.jTextArea, "Error!!! 发送请求：'" + commandType + "' '" + commandContent + "' '" + targetIp + "'失败！！ " + e.getMessage(), ReadConfig.commandStateShowLineCount);
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
        }
    }

    /**
     * 获得反馈
     *
     * @return 如果成功获得反馈，则返回true；否则返回false
     */
    private boolean getResponse() {
        InputStream is = null;
        DataInputStream di = null;
        boolean returnFlag = false;
        try {
            is = socket.getInputStream();
            di = new DataInputStream(is);
            byte[] temp = new byte[1];
            int flag = 0;
            ArrayList tempByteList = new ArrayList();
            int i = 0;
font-size: 1em; margin-top: 0px; margin-right: 0px; margin-

  


  
    
    分享到：
      
      
    
  

  
    
      openfire3.6.3插件开发方法
      |
      Log4J使用完全手册(转)
    
  
  
    
      2010-07-14 22:10
      浏览 1076
      评论(0)
      
      
            
      查看更多