我想开发一个集群功能，查到用CSocket来实现比较可行，于是先用本程序进行了基本通讯的测试。通过服务端向客户端发送信息，由客户端处理后返回信息。
本程序包括了基本的服务端、客户端功能，实现了服务端与客户端通过CSocket进行双向通讯，不仅能实现信息传输，还能实现大型文件的不丢包传输。
它是压包、拆包的程序示例，也是不丢包传输的解决方案。
此程序还解决了内存泄露的问题。本程序在VS2019下运行通过。
2021-05-19 10:06:41
262KB
1
通过socket通讯实现服务器与客户端的连接。首先服务器利用udp广播发送自己的ip地址，客户端在收到广播后通过此ip以tcp连接的方式连接服务器来通讯。
2021-04-02 16:46:09
45KB
1
发生TCP粘包或拆包有很多原因，现列出常见的几点，可能不全面，欢迎补充，
1、要发送的数据大于TCP发送缓冲区剩余空间大小，将会发生拆包。
2、待发送数据大于MSS（最大报文长度），TCP在传输前将进行拆包。
3、要发送的数据小于TCP发送缓冲区的大小，TCP将多次写入缓冲区的数据一次发送出去，将会发生粘包。
4、接收数据端的应用层没有及时读取接收缓冲区中的数据，将发生粘包。
2021-03-21 17:28:27
87KB
1
@Component
public class RabbitmqConfig {
private final static String message = "web.socket.message";
private final static String messages = "send.socket.message";
@Bean
public Queue queueMessage() {
return new Queue(RabbitmqConfig.message);
}
@Bean
public Queue queueMessages() {
return new Queue(RabbitmqConfig.messages);
}
@Bean
TopicExchange exchange() {
return new TopicExchange("exchange");
}
@Bean
Binding bindingExchangeMessage(Queue queueMessage, TopicExchange exchange) {
return BindingBuilder.bind(queueMessage).to(exchange).with("web.#");
}
@Bean
Binding bindingExchangeMessages(Queue queueMessages, TopicExchange exchange) {
return BindingBuilder.bind(queueMessages).to(exchange).with("send.#");
}
}
ServerBootstrap bootstrap = new ServerBootstrap()
.group(bossGroup, workGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ServerChannelInitializer())
.localAddress(socketAddress)
//设置队列大小
.option(ChannelOption.SO_BACKLOG, 1024)
// 两小时内没有数据的通信时,TCP会自动发送一个活动探测数据报文
.childOption(ChannelOption.SO_KEEPALIVE, true);
//绑定端口,开始接收进来的连接
完整代码，下载有详细说明，使用于长报文通讯，将报文长度截取一定字节发送，便于网速传输中丢包
2021-02-27 12:07:16
86.46MB