欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

关于Socket的解析以及双方即时通讯的java实现方法

程序员文章站 2024-03-04 16:15:05
在java编程之中,我们通常都会接触到网络编程,那么不可避免地就会接触到socket通信,下面我将对socket进行简单的解析,并给出双方通讯的代码实现方案 首先我们来介...

在java编程之中,我们通常都会接触到网络编程,那么不可避免地就会接触到socket通信,下面我将对socket进行简单的解析,并给出双方通讯的代码实现方案

首先我们来介绍一下整个socket的通信过程

关于Socket的解析以及双方即时通讯的java实现方法

首先服务端先创建一个socketserver,那么创建一个socketserver需要我们指定端口号,如下

serversocket serversocket=new serversocket(8888);

像上面这样我们就简单的开了一个端口号为8888的serversocket了

接下来我们需要去接收来自客户端的连接请求,也就是图中的other socket,我们可以利用sockerserver的accept方法来建立连接,并且这个方法会返回一个socket,用于和other socker进行通信,简单来说,我们就是利用sockerserver来获取socket,然后利用这个socket和别人通信

接下来我们获取socket的输入输出流,实现发送和接收信息,到此,我们已经知道两方进行socket通信的基本思路了

接下来我们来看看关于serversocket以及socket的一些关键方法

serversocket

首先我们看一下serversocket的构造方法,一共有4种:

1、无参的构造方法 :

serversocket(), 返回没有绑定端口号的serversocket实例
2、含一个参数的构造方法 :

serversocket(int port),返回绑定给定端口号的serversocket实例

3、含两个参数的构造方法 :

serversocket(int port, int backlog),返回绑定给定端口号的serversocket实例,并且设定同步队列(syns queue)的大小

4、含三个参数的构造方法:

serversocket(int port, int backlog, inetaddress bindaddr),返回绑定给定端口号的serversocket实例,并且设定同步队列(syns queue)的大小以及绑定给定的ip地址

主要看它的一些方法:

accept()

这个方法监听连接,一旦连接就返回一个socket用于通信,需要注意的是,该方法为阻塞方法,如果没有连接程序并不会继续执行下去

close()

关闭socket,如果accept还在阻塞的话,就会抛出一个socketexception的异常

关于serversocket就不多加赘述了,我们来看一看socket

socket

构造方法依然存在多种,这里只给出一个较为典型的

socket(string host, int port),第一个参数是主机的ip地址作为字符串传入,第二个参数为端口号

getinputstream(), getoutputstream()

获得socket的输入输出流,我们可以利用bufferreader以及printwriter来对这两个流进行操作,如下:

  bufferreader reader = new bufferedreader(
                  new inputstreamreader(socket.getinputstream()));
  printwriter writer = new printwriter(
                  new outputstreamwriter(socket.getoutputstream()));

下面简单编写一个双方互相通信的java实现

首先是服务端

import java.io.*;
import java.net.serversocket;
import java.net.socket;
import java.util.scanner;
/**
* created by mezereon on 2017/3/1.
*/
public class tcpserver {
 private socket socket;
 private serversocket serversocket;
 private bufferedreader reader;
 private printwriter writer;
 private scanner scanner = new scanner(system.in);
 //开启服务
 public void run() throws ioexception {
     startthesocket();
 }
 public void startthesocket() throws ioexception {
   serversocket=new serversocket(18080); //打开18080端口等待连接
   acceptthesocket();//接受连接并且初始化socket,reader,writer
   openthenewthreadtogetmessagefromclient();
   while(true) {   
      getyourmessage();//获取键盘数据并作为输入
   }
 }
 //接受连接并且初始化socket,reader,writer
 private void acceptthesocket() throws ioexception {
   socket=serversocket.accept();//阻塞方法,用于接受socket连接
   system.out.println("some one connect me ,it is "+socket.getlocalsocketaddress());//打印地址
   system.out.println("it's port is "+socket.getport());//打印端口号
   reader = new bufferedreader(new inputstreamreader(socket.getinputstream()));//获得输入流
   writer = new printwriter(new outputstreamwriter(socket.getoutputstream()));//获得输出流
 }
 //扫描键盘并输入数据
 private void getyourmessage() throws ioexception {
   string yourmessage = scanner.nextline();
   checkyourmessage(yourmessage);//检查发送给客户端的信息
   writer.println(yourmessage);//发送信息
   writer.flush();//flush方法用于清空缓冲区,注意的是如果不flush你的信息可能发不出去一直存留在缓冲区
 }
 //用于检查是否退出
 private void checkyourmessage(string yourmessage) throws ioexception {
   //关闭各种
   if (yourmessage.equals("exit")) {
     socket.close();
     writer.close();
     reader.close();
     system.exit(0);
   }
 }
 //开启一个新的线程来监听客户端发来的信息
 private void openthenewthreadtogetmessagefromclient() throws ioexception {
   //开启一个新的线程
   new thread(new runnable() {
     @override
     public void run() {
       getthemessagefromclient();
     }
   }).start();

 }
 //不断循环来获取客户端发来的信息
 private void getthemessagefromclient() {
   while(true) {
     string messagefromclient = null;
     try {
       messagefromclient = reader.readline();
     } catch (ioexception e) {
       e.printstacktrace();
     }
     printthemessage(messagefromclient);//打印客户端发来的信息
   }
 }
 //打印客户端发来的信息
 private void printthemessage(string messagefromclient) {
   if(messagefromclient!=null)
     system.out.println("he say:"+messagefromclient);
 }    
}

然后开始编写客户端:

import java.io.*;
import java.net.socket;
import java.util.scanner;

/**
 * created by mezereon on 2017/2/27.
 */
public class tcpclient {

  private socket socket;
  private bufferedreader reader ;
  private printwriter writer;
  private scanner scanner = new scanner(system.in);

  //开启socket来连接
  public void run() throws ioexception{
      startthesocket();
  }

  //开始连接服务端
  private void startthesocket() throws ioexception{
      toconnecttheserver();//创建socket并初始化
      openthethreadtoreceiveinfofromserver();//开启一个新的线程来接受服务端发来的信息

      //一个循环,用于读取键盘的输入
      while(true) {
        string yourmessage = scanner.nextline();
        //不为空则发送信息
        if(yourmessage!=null) {
          writer.println(yourmessage);
          writer.flush();//记得flush清空缓冲区
        }
        //判断是否退出
        if (yourmessage.equals("exit")) {
          disconnect();
          system.exit(0);
        }
      }
  }

  //创建一个socket来连接本机的18080端口的服务端并初始化reader和writer
  private void toconnecttheserver() throws ioexception {
    socket=new socket("127.0.0.1",18080);
    reader = new bufferedreader(new inputstreamreader(socket.getinputstream()));
    writer = new printwriter(new outputstreamwriter(socket.getoutputstream()),true);
  }

  private void openthethreadtoreceiveinfofromserver() throws ioexception {
    new thread(new runnable() {
      @override
      public void run() {
        try {
          printmessage();//打印从服务端收到的信息
        } catch (ioexception e) {
          e.printstacktrace();
        }
      }
    }).start();
  }

  //循环不断读取服务端的信息
  private void printmessage() throws ioexception {
    while (true) {
      string messagefromserver = null;
      try {
        messagefromserver = reader.readline();//读取信息
        system.out.println("he say:" + messagefromserver);//打印信息
      } catch (ioexception e) {
        e.printstacktrace();
      } catch (nullpointerexception e) {

      }
      if(messagefromserver.equals("exit")){
        disconnect();//关闭连接
        system.exit(0);
      }
    }
  }

  //关闭各种
  private void disconnect() throws ioexception {
    socket.close();
    reader.close();
    writer.close();
  }

}

至此,关于socket通信简单的介绍以及利用java进行简单的通信的实现就结束了~

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。