itcp模块设置显示连接服务器失败请重新连接

重启一下。

虚拟机上安装网络调试助手创建一个文件夹把这个deb文件放进去，然后输入安装命令安装完成后输入可以发现有两个路径，上面那个是软件的桌面图标的绝对路径，下面那个是软件的绝对路径。我选择切换到软件本身的绝对路径，然后用./mNetAssist即可打开文件。

netty v3.9.4

websocket连接建立前，客户端需要与服务器进行握手（http协议） 确认websocket连接，也就是说在处理websocket请求前，必需要处理一些http请求。

websocket到现在为止，已经有多个版本，netty有相应的对应类，这部分处理一般不需要人工干预。

如果运行正常的话，会在页面的文本框中显示1-20记数。

可以通过firefox或chrome的开发人员工具，显看浏览器与服务器的交互。

主要是HttpServerChannelHandler2，加了些注释和少量debug代码。

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

package org.sl.demo.httpserver1

import java.util.List

import java.util.Map

import org.jboss.netty.channel.Channel

import org.jboss.netty.channel.ChannelHandlerContext

import org.jboss.netty.channel.MessageEvent

import org.jboss.netty.channel.SimpleChannelHandler

import org.jboss.netty.handler.codec.http.DefaultHttpResponse

import org.jboss.netty.handler.codec.http.HttpHeaders

import org.jboss.netty.handler.codec.http.HttpMethod

import org.jboss.netty.handler.codec.http.HttpRequest

import org.jboss.netty.handler.codec.http.HttpResponseStatus

import org.jboss.netty.handler.codec.http.HttpVersion

import org.jboss.netty.handler.codec.http.websocketx.CloseWebSocketFrame

import org.jboss.netty.handler.codec.http.websocketx.PingWebSocketFrame

import org.jboss.netty.handler.codec.http.websocketx.PongWebSocketFrame

import org.jboss.netty.handler.codec.http.websocketx.TextWebSocketFrame

import org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame

import org.jboss.netty.handler.codec.http.websocketx.WebSocketServerHandshaker

import org.jboss.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory

public class HttpServerChannelHandler2 extends SimpleChannelHandler{

public static boolean debug = true

@Override

public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {

Channel ch = e.getChannel()

Object msg = e.getMessage()

if(debug){

System.out.println("---------------")

System.out.println("message: "+msg.getClass())

}

//虽然是websocket，但在建立websocket连接前，先进行http握手,所以，这时也要处理http请求

//在http握手完成后，才是websocket下的通信

if(msg instanceof HttpRequest){

processHttpRequest(ch, (HttpRequest)msg)

}else if(msg instanceof WebSocketFrame){

processWebsocketRequest(ch,(WebSocketFrame)msg)

}else{

//未处理的请求类型

}

}

//这个方法：

//1.完成websocket前的http握手

//2.屏蔽掉非websocket握手请求

void processHttpRequest(Channel channel,HttpRequest request){

HttpHeaders headers = request.headers()

if(debug){

List<Map.Entry<String,String>>ls = headers.entries()

for(Map.Entry<String,String>i: ls){

System.out.println("header "+i.getKey()+":"+i.getValue())

}

}

//屏蔽掉非websocket握手请求

//只接受http GET和headers['Upgrade']为'websocket'的http请求

if(!HttpMethod.GET.equals(request.getMethod())

|| !"websocket".equalsIgnoreCase(headers.get("Upgrade"))){

DefaultHttpResponse resp = new DefaultHttpResponse(

HttpVersion.HTTP_1_1,

HttpResponseStatus.BAD_REQUEST)

channel.write(resp)

channel.close()

return

}

WebSocketServerHandshakerFactory wsShakerFactory = new WebSocketServerHandshakerFactory(

"ws://"+request.headers().get(HttpHeaders.Names.HOST),

null,false )

WebSocketServerHandshaker wsShakerHandler = wsShakerFactory.newHandshaker(request)

if(null==wsShakerHandler){

//无法处理的websocket版本

wsShakerFactory.sendUnsupportedWebSocketVersionResponse(channel)

}else{

//向客户端发送websocket握手,完成握手

//客户端收到的状态是101 sitching protocol

wsShakerHandler.handshake(channel, request)

}

}

//websocket通信

void processWebsocketRequest(Channel channel, WebSocketFrame request){

if(request instanceof CloseWebSocketFrame){

channel.close()

}else if(request instanceof PingWebSocketFrame){

channel.write(new PongWebSocketFrame(request.getBinaryData()))

}else if(request instanceof TextWebSocketFrame){

//这个地方 可以根据需求，加上一些业务逻辑

TextWebSocketFrame txtReq = (TextWebSocketFrame) request

if(debug){ System.out.println("txtReq:"+txtReq.getText())}

//向ws客户端发送多个响应

for(int i=1i<=20i++){

channel.write(new TextWebSocketFrame(""+i))

try{Thread.sleep(300)}catch(Exception ex){}

}

}else{

//WebSocketFrame还有一些

}

}

}

其他类跟网上的差不多：

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

package org.sl.demo.httpserver1

import java.net.InetSocketAddress

import java.util.concurrent.Executors

import org.jboss.netty.bootstrap.ServerBootstrap

import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory

public class HttpServer implements Runnable{

int port = 80

public HttpServer(int port){

this.port = port

}

@Override

public void run() {

ServerBootstrap b = new ServerBootstrap(

new NioServerSocketChannelFactory(

Executors.newCachedThreadPool(),

Executors.newCachedThreadPool()))

b.setPipelineFactory(new HttpServerChannelPipelineFactory())

b.setOption("child.tcpNoDelay", true)

b.setOption("child.keepAlive", true)

b.bind(new InetSocketAddress(port))

}

public static void main(String[] args){

new HttpServer(80).run()

}

}

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

package org.sl.demo.httpserver1

import org.jboss.netty.channel.ChannelPipeline

import org.jboss.netty.channel.ChannelPipelineFactory

import org.jboss.netty.channel.Channels

import org.jboss.netty.handler.codec.http.HttpRequestDecoder

import org.jboss.netty.handler.codec.http.HttpResponseEncoder

import org.jboss.netty.handler.codec.http.websocketx.WebSocket00FrameDecoder

import org.jboss.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder

public class HttpServerChannelPipelineFactory implements ChannelPipelineFactory {

@Override

public ChannelPipeline getPipeline() throws Exception {

ChannelPipeline cp = Channels.pipeline()

cp.addLast("decoder", new HttpRequestDecoder())

// cp.addLast("decoder", new WebSocket00FrameDecoder())

cp.addLast("encoder", new HttpResponseEncoder())

// cp.addLast("downhandler", new HttpServerDownstreamHandler())

// cp.addLast("uphandler", new HttpServerUpstreamHandler())

cp.addLast("handler", new HttpServerChannelHandler2())

return cp

}

}

测试页面：

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

<html>

<head>

<script >

function connect1(){

alert('connect1')

var ta = document.getElementById('responseText')

var socket = new WebSocket('ws://127.0.0.1/websocket')

if (window.WebSocket) {

}else{

alert('Your browser does not support Web Socket.')

return

}

socket.onopen = function(event) {

ta.value = "Web Socket opened!"

}

socket.onmessage = function(event) {

ta.value = event.data

}

socket.onclose = function(event) {

ta.value = "Web Socket closed"

}

}

function connect() {

alert('connect')

var socket

if (!window.WebSocket) {

window.WebSocket = window.MozWebSocket

}

if (window.WebSocket) {

socket = new WebSocket("ws://127.0.0.1/websocket")

socket.onmessage = function(event) {

var ta = document.getElementById('responseText')

ta.value = event.data

}

socket.onopen = function(event) {

var ta = document.getElementById('responseText')

ta.value = "Web Socket opened!"

socket.send('hello')

}

socket.onclose = function(event) {

var ta = document.getElementById('responseText')

ta.value = "Web Socket closed"

}

socket.onerror = function(event){

}

} else {

alert("Your browser does not support Web Socket.")

}

}

</script>

</head>

<body>

<input type="button" onclick="connect1()" value="ws connect1"/><br/><br/>

<input type="button" onclick="connect()" value="ws connect"/><br/><br/>

<input id="responseText" type="text" value="123456"/>

</body>

</html>

信捷plc设置软件窗口在菜单栏中。打开编程软件，型号是XC的PLC选择“XC系列编程工具”，型号是XD的PLC选择“信捷PLC编程工具软件”，点击菜单栏“选项”选择“TCP/IP设备设置。

---