文件名称:
基于naga开发的TCP客户端/服务器程序
开发工具:
文件大小: 686kb
下载次数: 0
上传时间: 2013-04-13
详细说明： 1、利用“naga-2_1-r42.jar”包进行二次开发； 2、调用NIOService类中的打开socket和serverSocket函数进行编程； 3、例如，服务器端： NIOService service1 = new NIOService(); NIOServerSocket serverSocket = service1.openServerSocket(port); // 设置监听事件，包括打开监听后，关闭后这两个： serverSocket.listen(new ServerSocketObserverAdapter() { public void newConnection(NIOSocket nioSocket) { // 可在此处添加处理事件 } public void serverSocketDied(Exception exception) { // 关闭serverSocket处理 } }); // 还需要一个循环事件，执行事件监听，此处可能需要使用到多线程编程 // 设置接收链接方 式 serverSocket.setConnectionAcceptor(ConnectionAcceptor.ALLOW); while (true) { // 循环不断监听事件 service1.selectBlocking(1); } 4、又例如，客户端，包括链接上，接收包，关闭链接后三个事件和write()方法： NIOService service2 = new NIOService(); NIOSocket socket = service2.openSocket(InetAddress.getLocalHost(), port); // 设置接收包格式 nioSocket.setPacketReader(new RegularPacketReader(1, true)); nioSocket.setPacketWriter(new RegularPacketWriter(1, true)); nioSocket.listen(new SocketObserverAdapter() { public void connectionBroken(NIOSocket nioSocket, Exception arg1) { // 打开后处理 System.out.println("Client ip:" + nioSocket.getIp() +" port:"+nioSocket.getPort()+ " disconnected."); nioSocket.close(); isConnected = false; } public void connectionOpened(NIOSocket nioSocket) { // 关闭链接后处理 System.out.println("Client ip:" + nioSocket.getIp() +" port:"+nioSocket.getPort()+ " connected."); } public void packetReceived(NIOSocket nioSocket, byte[] packet) { revNum = nioSocket.getBytesRead(); // 包处理 revDataAndParse(packet); }}); // 还需要一个循环监听事件并执行，此处可能需要使用到多线程编程 while (true) { service2.selectBlocking(1); } 5、该项目开发过程基本上是以上3、4点的封装过程，利用接口编程，实现一个客户端基础类（TCPClientBase） 和服务器端基础类（TCPServerBase），其中客户端基础类有两种方式，一种是使用于单独的客户端的单元；另 一种使用与服务器端接收一个链接后的单元； 6、项目类使用： 1) communication.tcp.client.TCPClientBase是基础抽象类，任何外部使用都必须继承该类，并重写一 个“protected abstract void revDataAndParse(byte[] data);”方法，建议外部重写时，设置成protected&private 以防止类外部调用。同样在继承该基础类时，可以在继承类中添加各种需要的引用及必要的方法，实例在 communication.tcp.example.TCPClientUnit体现，重写revDataAndParse方法如下： /** * 处理数据将数据置于队列中，或者直接解析....... */ protected void revDataAndParse(byte[] data) { // SystemOut.arrayToHexString(data); // sendData(data); // System.out.println(new String(data)); } 2) communication.tcp.server.TCPServerBase也是基础抽象类，任何外部使用都必须继承该类，并重写至少包括一些内容： /** * 服务器端构造方法 * @param ip * @param port * @throws ClassNotFoundException */ @SuppressWarnings("unchecked") public TCPServerUnit(String ip, int port) throws ClassNotFoundException { // 注意保持与泛型中的类一致性 super(ip, port,(Class) Class.forName(TCPClientUnit4Server.class.getName())); } 7、弊端：程序为未经过严格的验证，使用效果如何未知；客户端中的接收包有一定的局限性，接收数据包不利于开发解析，对于实时性要求比较 高的系统不一定适用，如modbusTCP。 8、详细使用过程，请参考doc目录中的api帮助文档。 ...展开收缩
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
