Java Socket初步详解

网络编程的基本模型就是客户机到服务器模型 简单的说就是两个进程之间相互通讯 然后其中一个必须提供一个固定的位置 而另一个则只需要知道这个固定的位置 并去建立两者之间的联系 然后完成数据的通讯就可以了 这里提供固定位置的通常称为服务器 而建立联系的通常叫做客户端 基于这个简单的模型 就可以进入网络编程啦

Java对这个模型的支持有很多种Api 而这里我只想介绍有关Socket的编程接口 对于Java而言已经简化了Socket的编程接口 首先我们来讨论有关提供固定位置的服务方是如何建立的 Java提供了ServerSocket来对其进行支持 事实上当你创建该类的一个实力对象并提供一个端口资源你就建立了一个固定位置可以让其他计算机来访问你 ServerSocket server=new ServerSocket( );这里稍微要注意的是端口的分配必须是唯一的 因为端口是为了唯一标识每台计算机唯一服务的 另外端口号是从 ~ 之间的 前 个端口已经被Tcp/Ip 作为保留端口 因此你所分配的端口只能是 个之后的 好了 我们有了固定位置 现在所需要的就是一根连接线了 该连接线由客户方首先提出要求 因此Java同样提供了一个Socket对象来对其进行支持 只要客户方创建一个Socket的实例对象进行支持就可以了 Socket client

=new Socket(InetAddress getLocalHost() );客户机必须知道有关服务器的IP地址 对于著一点Java也提供了一个相关的类InetAddress 该对象的实例必须通过它的静态方法来提供 它的静态方法主要提供了得到本机IP 和通过名字或IP直接得到InetAddress的方法

上面的方法基本可以建立一条连线让两台计算机相互交流了 可是数据是如何传输的呢？事实上I/O *** 作总是和网络编程息息相关的 因为底层的网络是继续数据的 除非远程调用 处理问题的核心在执行上 否则数据的交互还是依赖于IO *** 作的 所以你也必须导入java io这个包 java的IO *** 作也不复杂 它提供了针对于字节流和Unicode的读者和写者 然后也提供了一个缓冲用于数据的读写

BufferedReader in=new BufferedReader(new InputStreamReader(server getInputStream()));

PrintWriter out=new PrintWriter(server getOutputStream());

上面两句就是建立缓冲并把原始的字节流转变为Unicode可以 *** 作 而原始的字节流来源于Socket的两个方法 getInputStream()和getOutputStream()方 分别用来得到输入和输出 那么现在有了基本的模型和基本的 *** 作工具 我们可以做一个简单的Socket例程了

服务方:

import java io ;

import ;

public class MyServer {

public static void main(String[] args) throws IOException{

ServerSocket server=new ServerSocket( );

Socket client=server accept();

BufferedReader in=new BufferedReader(new InputStreamReader(client getInputStream()));

PrintWriter out=new PrintWriter(client getOutputStream());

while(true){

String str=in readLine();

System out println(str);

out println( has receive );

out flush();

if(str equals( end ))

break;

}

client close();

}

}

这个程序的主要目的在于服务器不断接收客户机所写入的信息只到 客户机发送 End 字符串就退出程序 并且服务器也会做出 Receive 为回应 告知客户机已接收到消息

客户机代码:

import ;

import java io ;

public class Client{

static Socket server;

public static void main(String[] args)throws Exception{

server=new Socket(InetAddress getLocalHost() );

BufferedReader in=new BufferedReader(new InputStreamReader(server getInputStream()));

PrintWriter out=new PrintWriter(server getOutputStream());

BufferedReader wt=new BufferedReader(new InputStreamReader(System in));

while(true){

String str=wt readLine();

out println(str);

out flush();

if(str equals( end )){

break;

}

System out println(in readLine());

}

server close();

}

}

客户机代码则是接受客户键盘输入 并把该信息输出 然后输出 End 用来做退出标识

这个程序只是简单的两台计算机之间的通讯 如果是多个客户同时访问一个服务器呢？你可以试着再运行一个客户端 结果是会抛出异常的 那么多个客户端如何实现呢

其实 简单的分析一下 就可以看出客户和服务通讯的主要通道就是Socket本身 而服务器通过accept方法就是同意和客户建立通讯 这样当客户建立Socket的同时 服务器也会使用这一根连线来先后通讯 那么既然如此只要我们存在多条连线就可以了 那么我们的程序可以变为如下:

服务器:

import java io ;

import ;

public class MyServer {

public static void main(String[] args) throws IOException{

ServerSocket server=new ServerSocket( );

while(true){

Socket client=server accept();

BufferedReader in=new BufferedReader(new InputStreamReader(client getInputStream()));

PrintWriter out=new PrintWriter(client getOutputStream());

while(true){

String str=in readLine();

System out println(str);

out println( has receive );

out flush();

if(str equals( end ))

break;

}

client close();

}

}

}

这里仅仅只是加了一个外层的While循环 这个循环的目的就是当一个客户进来就为它分配一个Socket直到这个客户完成一次和服务器的交互 这里也就是接受到客户的 End 消息 那么现在就实现了多客户之间的交互了 但是 问题又来了 这样做虽然解决了多客户 可是是排队执行的 也就是说当一个客户和服务器完成一次通讯之后下一个客户才可以进来和服务器交互 无法做到同时服务 那么要如何才能同时达到既能相互之间交流又能同时交流呢？很显然这是一个并行执行的问题了 所以线程是最好的解决方案

那么下面的问题是如何使用线程 首先要做的事情是创建线程并使得其可以和网络连线取得联系 然后由线程来执行刚才的 *** 作 要创建线程要么直接继承Thread要么实现Runnable接口 要建立和Socket的联系只要传递引用就可以了 而要执行线程就必须重写run方法 而run方法所做的事情就是刚才单线程版本main所做的事情 因此我们的程序变成了这样:

import ;

import java io ;

public class MultiUser extends Thread{

private Socket client;

public MultiUser(Socket c){

this client=c;

}

public void run(){

try{

BufferedReader in=new BufferedReader(new InputStreamReader(client getInputStream()));

PrintWriter out=new PrintWriter(client getOutputStream());

//Mutil User but can t parallel

while(true){

String str=in readLine();

System out println(str);

out println( has receive );

out flush();

if(str equals( end ))

break;

}

client close();

}catch(IOException ex){

}finally{

}

}

public static void main(String[] args)throws IOException{

ServerSocket server=new ServerSocket( );

while(true){

//transfer location change Single User or Multi User

MultiUser mu=new MultiUser(server accept());

mu start();

}

}

}

lishixinzhi/Article/program/Java/hx/201311/27013

s

=

new

socket("127001",

8880)

前面那个ip是服务器的地址，只要这个ip写正确了，服务器放在哪里，客户端都能连上去的。

1270。01最简单的解释就是本机地址，你用这个ip，访问的就是你自己。

你可以去服务器上查看一下网络地址，然后把1270。01换成服务器的ip。

java获取固定IP发来所有的数据包，需要实现网络嗅探的部分功能：

代码如下;

/

 JpcapTipjava

/

package m;

import jpcapPacketReceiver;

import jpcapJpcapCaptor;

import jpcappacket;

import jpcapNetworkInterface;

import jpcapNetworkInterfaceAddress;

//import javanetInetAddress;

//import javanetUnknownHostException;

public class JpcapTip implements PacketReceiver {

public void receivePacket(Packet packet) {

   Systemoutprintln("");

   /IP数据报报文头/

   byte[] l=packetheader;     

   /

   for (int t=0;t<21;t++){

    Systemoutprint(l[t]+"  ");

   }

   /

   String str="";

    Systemoutprint("报文头 : ");

    for (int i=0;i<llength;i++) {

     //str=str+l;

     int m=0;

     m=l[i];

     m=m<<24;

     m=m>>>24;

     str=str+IntegertoHexString(m);

     //Systemoutprint("          "+l[i]);

    }

   Systemoutprintln(str);

   int d=llength;

   Systemoutprintln("首部长度 ："+(d8)+"bit");

  

   /分析源IP地址和目的IP地址/

   /分析协议类型/

   /

   if(packetgetClass()equals(IPPacketclass)) {

    IPPacket ipPacket=(IPPacket)packet;

    byte[] iph=ipPacketoption;

    String iphstr=new String(iph);

    Systemoutprintln(iphstr);

   }

   /

   if(packetgetClass()equals(ARPPacketclass))

   {

    Systemoutprintln("协议类型 ：ARP协议");

    try {

     ARPPacket arpPacket = (ARPPacket)packet;

     Systemoutprintln("源网卡MAC地址为 ："+arpPacketgetSenderHardwareAddress());

     Systemoutprintln("源IP地址为 ："+arpPacketgetSenderProtocolAddress());

     Systemoutprintln("目的网卡MAC地址为 ："+arpPacketgetTargetHardwareAddress());

     Systemoutprintln("目的IP地址为 ："+arpPacketgetTargetProtocolAddress());

} catch( Exception e ) {

     eprintStackTrace();

    } 

   }

   else 

    if(packetgetClass()equals(UDPPacketclass))

    {

     Systemoutprintln("协议类型 ：UDP协议");

     try {

      UDPPacket udpPacket = (UDPPacket)packet;

      Systemoutprintln("源IP地址为 ："+udpPacketsrc_ip);

      int tport = udpPacketsrc_port;

      Systemoutprintln("源端口为："+tport);

      Systemoutprintln("目的IP地址为 ："+udpPacketdst_ip);

      int lport = udpPacketdst_port;

      Systemoutprintln("目的端口为："+lport);

     } catch( Exception e ) {

      eprintStackTrace();

     } 

    }

   else

    if(packetgetClass()equals(TCPPacketclass)) {

     Systemoutprintln("协议类型 ：TCP协议");

     try {

      TCPPacket tcpPacket = (TCPPacket)packet;

      int tport = tcpPacketsrc_port;

      Systemoutprintln("源IP地址为 ："+tcpPacketsrc_ip);

      Systemoutprintln("源端口为："+tport);

      Systemoutprintln("目的IP地址为 ："+tcpPacketdst_ip);

      int lport = tcpPacketdst_port;

      Systemoutprintln("目的端口为："+lport);

     } catch( Exception e ) {

      eprintStackTrace();

     }

    }

   else

    if(packetgetClass()equals(ICMPPacketclass))

     Systemoutprintln("协议类型 ：ICMP协议");

   else

     Systemoutprintln("协议类型 ：GGP、EGP、JGP协议或OSPF协议或ISO的第4类运输协议TP4");

/IP数据报文数据/

   byte[] k=packetdata;   

   String str1="";

    Systemoutprint("数据 : ");

     for(int i=0;i<klength;i++) {

      //int m=0;

      //m=k[i];

      //m=m<<24;

      //m=m>>>24;

      //str1=str+IntegertoHexString(m);

      str1 = new String(k);

      //str1=str1+k[i];

      //Systemoutprint("          "+k[i]);

     }

     Systemoutprintln(str1);

   Systemoutprintln("数据报类型 : "+packetgetClass());

   Systemoutprintln("");

}

public static void main(String[] args) throws Exception{

   // TODO 自动生成方法存根

  

   NetworkInterface[] devices = JpcapCaptorgetDeviceList();        //getDeviceList();

   //for (int i =0; i<deviceslength;i++) {

    int a=0;

    //try {

    /本地网络信息/

    byte[] b=devices[1]mac_address; //网卡物理地址

    //}

    //catch() {}

    Systemoutprint("网卡MAC : 00");   

    for (int j=0;j<blength;j++){

     //a=a<<8;

     a=b[j];

     a=a<<24;

     a=a>>>24;

     Systemoutprint(IntegertoHexString(a));

    }

    Systemoutprintln();

    NetworkInterfaceAddress[] k=devices[1]addresses;

   

    //Systemoutprintln("网卡MAC : "+IntegertoHexString(a));

    for(int n=0;n<klength;n++) {

     Systemoutprintln("本机IP地址 : "+k[n]address);     //本机IP地址

     Systemoutprintln("子网掩码   : "+k[n]subnet);      //子网掩码

    }

    Systemoutprintln("网络连接类型 : "+devices[1]datalink_description);

   //}

   NetworkInterface deviceName = devices[1];

   /将网卡设为混杂模式下用网络设备deviceName/

   JpcapCaptor jpcap =JpcapCaptoropenDevice(deviceName, 2000, false, 1);           //openDevice(deviceName,1028,false,1);

   jpcaploopPacket(-1,new JpcapTip());

}

}

以上就是关于Java Socket初步详解全部的内容，包括:Java Socket初步详解、java Socket编程 客户端与服务器端在两个网里怎么实现连接 s = new Socket("127.0.0.1", 8880);这个IP怎么、java如何编程实现，获取固定IP发来所有的数据包 等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！