socket服务器搭建(PLC SOCKET TCP的服务器和客户端)

这样,tomcat启动时便加载这个servlet,其init方法会自动被调用 相当于server socket 写在servlet里 具体可以百度"WEB服务器启动时加载一个ServerSocket服务"

（1）设置用户验证和记账功能，可按用户进行记账，没有登记的用户无权通过代理服务器访问Internet网。并对用户的访问时间、访问地点、信息流量进行统计。 (2）对用户进行分级管理，设置不同用户的访问权限，对外界或内部的Internet地址进行过滤，设置不同的访问权限。 (3）增加缓冲器（Cache)，提高访问速度，对经常访问的地址创建缓冲区，大大提高热门站点的访问效率。通常代理服务器都设置一个较大的硬盘缓冲区（可能高达几个GB或更大），当有外界的信息通过时，同时也将其保存到缓冲区中，当其他用户再访问相同的信息时，则直接由缓冲区中取出信息，传给用户，以提高访问速度。

请自行参考TCP/udp连接基础解释，然后根据自身问题进行排查。

其实，在服务器的选择上很广，基本上，主流语言都有WebSocket的服务器端实现，而我们作为前端开发工程师，当然要选择现在比较火热的NodeJS作为我们的服务器端环境了。 NodeJS本身并没有原生的WebSocket支持，但是有第三方的实现（大家要是有兴趣的话，完全可以参考WebSocket协议来做自己的实现），我们选择了“ws”作为我们的服务器端实现。由于本文的重点是讲解WebSocket，所以，对于NodeJS不做过多的介绍，不太熟悉的朋友可以去参考NodeJS入门指南（http://www.nodebeginner.org/index-zh-cn.html）。安装好NodeJS之后，我们需要安装“ws”，也就是我们的WebSocket实现，安装方法很简单，在终端或者命令行中输入：npm install ws，等待安装完成就可以了。接下来，我们需要启动我们的WebSocket服务。首先，我们需要构建自己的HTTP服务器，在NodeJS中构建一个简单的HTTP服务器很简单，so easy。代码如下：var app = http.createServer(onRequest ).listen( 8888 );onRequest()作为回调函数，它的作用是处理请求，然后做出响应，实际上就是根据接收的URL，在服务器上查找相应的资源，最终返回给浏览器。在构建了HTTP服务器后，我们需要启动WebSocket服务，代码如下：var WebSocketServer = require('ws').Server;var wss = new WebSocketServer( { server : app } ); 从代码中可以看出，在初始化WebSocket服务时，把我们刚才构建好的HTTP实例传递进去就好。到这里，我们的服务端代码差不多也就编写完成了。怎么样？很简单吧。
其实，在服务器的选择上很广，基本上，主流语言都有WebSocket的服务器端实现，而我们作为前端开发工程师，当然要选择现在比较火热的NodeJS作为我们的服务器端环境了。 NodeJS本身并没有原生的WebSocket支持，但是有第三方的实现（大家要是有兴趣的话，完全可以参考WebSocket协议来做自己的实现），我们选择了“ws”作为我们的服务器端实现。由于本文的重点是讲解WebSocket，所以，对于NodeJS不做过多的介绍，不太熟悉的朋友可以去参考NodeJS入门指南（http://www.nodebeginner.org/index-zh-cn.html）。安装好NodeJS之后，我们需要安装“ws”，也就是我们的WebSocket实现，安装方法很简单，在终端或者命令行中输入：npm install ws，等待安装完成就可以了。接下来，我们需要启动我们的WebSocket服务。首先，我们需要构建自己的HTTP服务器，在NodeJS中构建一个简单的HTTP服务器很简单，so easy。代码如下：var app = http.createServer(onRequest ).listen( 8888 );onRequest()作为回调函数，它的作用是处理请求，然后做出响应，实际上就是根据接收的URL，在服务器上查找相应的资源，最终返回给浏览器。在构建了HTTP服务器后，我们需要启动WebSocket服务，代码如下：var WebSocketServer = require('ws').Server;var wss = new WebSocketServer( { server : app } ); 从代码中可以看出，在初始化WebSocket服务时，把我们刚才构建好的HTTP实例传递进去就好。到这里，我们的服务端代码差不多也就编写完成了。怎么样？很简单吧。
其实，在服务器的选择上很广，基本上，主流语言都有WebSocket的服务器端实现，而我们作为前端开发工程师，当然要选择现在比较火热的NodeJS作为我们的服务器端环境了。 NodeJS本身并没有原生的WebSocket支持，但是有第三方的实现（大家要是有兴趣的话，完全可以参考WebSocket协议来做自己的实现），我们选择了“ws”作为我们的服务器端实现。由于本文的重点是讲解WebSocket，所以，对于NodeJS不做过多的介绍，不太熟悉的朋友可以去参考NodeJS入门指南（http://www.nodebeginner.org/index-zh-cn.html）。安装好NodeJS之后，我们需要安装“ws”，也就是我们的WebSocket实现，安装方法很简单，在终端或者命令行中输入：npm install ws，等待安装完成就可以了。接下来，我们需要启动我们的WebSocket服务。首先，我们需要构建自己的HTTP服务器，在NodeJS中构建一个简单的HTTP服务器很简单，so easy。代码如下：var app = http.createServer(onRequest ).listen( 8888 );onRequest()作为回调函数，它的作用是处理请求，然后做出响应，实际上就是根据接收的URL，在服务器上查找相应的资源，最终返回给浏览器。在构建了HTTP服务器后，我们需要启动WebSocket服务，代码如下：var WebSocketServer = require('ws').Server;var wss = new WebSocketServer( { server : app } );从代码中可以看出，在初始化WebSocket服务时，把我们刚才构建好的HTTP实例传递进去就好。到这里，我们的服务端代码差不多也就编写完成了。怎么样？很简单吧。 望采纳！
先安装好NodeJS，然后用以下命令安装WebSocket npm install ws再用下面的命令在NodeJS中构建一个简单的HTTP服务器var app = http.createServer( onRequest ).listen( 8888 );再用下面的代码启动WebSocket服务var WebSocketServer = require('ws').Server;var wss = new WebSocketServer( { server : app } ); 做到这就差不多了。

package socket;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.ServerSocket;import java.net.Socket;public class SocketService {    //搭建服务器端    public static void main(String[] args) throws IOException{        SocketService socketService = new SocketService();//1、a)创建一个服务器端Socket，即SocketService        socketService.oneServer();    }    public  void oneServer(){        try{            ServerSocket server=null;            try{                server=new ServerSocket(5209);                //b)指定绑定的端口，并监听此端口。                System.out.println("服务器启动成功");                //创建一个ServerSocket在端口5209监听客户请求            }catch(Exception e) {                    System.out.println("没有启动监听："+e);                    //出错，打印出错信息            }            Socket socket=null;            try{                socket=server.accept();//2、调用accept()方法开始监听，等待客户端的连接                //使用accept()阻塞等待客户请求，有客户                //请求到来则产生一个Socket对象，并继续执行            }catch(Exception e) {                System.out.println("Error."+e);                //出错，打印出错信息            }//3、获取输入流，并读取客户端信息            String line;            BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));            //由Socket对象得到输入流，并构造相应的BufferedReader对象            PrintWriter writer=new PrintWriter(socket.getOutputStream());            //由Socket对象得到输出流，并构造PrintWriter对象            BufferedReader br=new BufferedReader(new InputStreamReader(System.in));            //由系统标准输入设备构造BufferedReader对象            System.out.println("Client:"+in.readLine());            //在标准输出上打印从客户端读入的字符串            line=br.readLine();            //从标准输入读入一字符串//4、获取输出流，响应客户端的请求            while(!line.equals("end")){            //如果该字符串为 "bye"，则停止循环                writer.println(line);                //向客户端输出该字符串                writer.flush();                //刷新输出流，使Client马上收到该字符串                System.out.println("Server:"+line);                //在系统标准输出上打印读入的字符串                System.out.println("Client:"+in.readLine());                //从Client读入一字符串，并打印到标准输出上                line=br.readLine();                //从系统标准输入读入一字符串            } //继续循环//5、关闭资源            writer.close(); //关闭Socket输出流            in.close(); //关闭Socket输入流            socket.close(); //关闭Socket            server.close(); //关闭ServerSocket        }catch(Exception e) {//出错，打印出错信息            System.out.println("Error."+e);        }    }}
服务器端代码：import java.io.IOException;import java.io.InputStream;import java.net.ServerSocket;import java.net.Socket;public class Server {    public void server(){        try {            ServerSocket serverSocket = new ServerSocket(8888); //建立服务器端的套接字，并监听8888端口            Socket socket = serverSocket.accept(); //如果有请求到达，则接受请求，并建立一个新的套接字            InputStream is = socket.getInputStream(); //获取此套接字上的输入流，用于接收消息            //接下来就是获取套接字里的字节流，并转化为字符串            byte[] bytes = new byte[1024];            int count;            StringBuilder sb = new StringBuilder();            while((count = is.read(bytes)) != -1){                sb.append(new String(bytes, 0, count));            }            is.close();            System.out.println(sb.toString());        } catch (IOException e) {            e.printStackTrace();        }    }    public static void main(String[] args) {        Server s = new Server();        s.server();    }}另附客户端：import java.io.IOException;import java.io.OutputStream;import java.net.InetSocketAddress;import java.net.Socket;public class Client {    public void client(){        try {            Socket socket = new Socket(); //建立套接字            socket.connect(new InetSocketAddress("127.0.0.1", 8888)); //连接到指定IP地址的主机，并指定端口号接收消息            OutputStream os = socket.getOutputStream(); //获取此连接上的输出流，用于发送数据            os.write(new String("Hello, world!").getBytes()); //将字符串转化为字节数组写入输出流            os.flush();//刷新此输出流，将字节流写入它们预期的目标            os.close(); //关闭连接，否则会报连接重置异常        } catch (IOException e) {            e.printStackTrace();        }    }    public static void main(String[] args) {        Client c = new Client();        c.client();    }}