文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

怎么在java中使用SocketChannel实现一个客户端

2023-06-14 17:04

关注

怎么在java中使用SocketChannel实现一个客户端?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。

常用的java框架有哪些

1.SpringMVC,Spring Web MVC是一种基于Java的实现了Web MVC设计模式的请求驱动类型的轻量级Web框架。2.Shiro,Apache Shiro是Java的一个安全框架。3.Mybatis,MyBatis 是支持普通 SQL查询,存储过程和高级映射的优秀持久层框架。4.Dubbo,Dubbo是一个分布式服务框架。5.Maven,Maven是个项目管理和构建自动化工具。6.RabbitMQ,RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。7.Ehcache,EhCache 是一个纯Java的进程内缓存框架。

1、步骤

(1)创建SocketChannel实例,并将其配置为非阻塞模式,只有在SocketChannel实例中,任何I/O操作都是非阻塞的。

(2)使用connect()方法连接服务器,同时使用while循环连续检测和完全连接。在需要立即进行I/O操作之前,必须使用finishConnect()来完成连接过程。

(3)用ByteBuffer读写字节,假如SelectableChannel是一种非阻塞模式,那么它的I/O操作读写字节可能比实际字节少,甚至没有。因此,我们使用循环连续的读写来确保读写完成。

2、实例

public class NonBlockingTCPClient {    public static void main(String[] args) {        byte[] data = "hello".getBytes();        SocketChannel channel = null;        try {            // 1. open a socket channel            channel = SocketChannel.open();            // adjust to be nonblocking            channel.configureBlocking(false);            // 2. init connection to server and repeatedly poll with complete            // connect() and finishConnect() are nonblocking operation, both return immediately            if (!channel.connect(new InetSocketAddress(InetAddress.getLocalHost(), 8899))) {                while (!channel.finishConnect()) {                    System.out.print(".");                }            }             System.out.println("Connected to server...");             ByteBuffer writeBuffer = ByteBuffer.wrap(data);            ByteBuffer readBuffer = ByteBuffer.allocate(data.length);            int totalBytesReceived = 0;            int bytesReceived;            // 3. read and write bytes            while (totalBytesReceived < data.length) {                if (writeBuffer.hasRemaining()) {                    channel.write(writeBuffer);                }                if ((bytesReceived = channel.read(readBuffer)) == -1) {                    throw new SocketException("Connection closed prematurely");                }                totalBytesReceived += bytesReceived;                System.out.print(".");            }            System.out.println("Server said: " + new String(readBuffer.array()));        } catch (IOException e) {            e.printStackTrace();        } finally {            // 4 .close socket channel            try {                if (channel != null) {                    channel.close();                }            } catch (IOException e) {                e.printStackTrace();            }        }    }}

看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注编程网行业资讯频道,感谢您对编程网的支持。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯