包含java中实现tcp通讯的词条

本篇文章给大家谈谈java中实现tcp通讯，以及对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、大神求教，如何实现JAVA以TCP实时互传通讯
• 2、TCP/IP协议 怎么用JAVA发送和接收二进制数据 要具体实例
• 3、编写一个简单的TCP通信程序。服务器发送“你好我是服务器”，客户端接收该信息并显示在屏幕上。用Java写
• 4、java如何实现基于TCP协议的socket传输
• 5、用java编写一个能进行简单TCP/IP通信的C/S程序
• 6、TCP和UDP通信有什么区别 如何分别用java实现？

大神求教，如何实现JAVA以TCP实时互传通讯

你可以上一个叫CSDN的网站上搜索相关内容，这种资源有很多人公开的，你可以搜索关键字JAVA实现socket

TCP/IP协议 怎么用JAVA发送和接收二进制数据 要具体实例

1.TCP/IP协议要求信息必须在块（chunk）中发送和接收，而块的长度必须是8位的倍数，因此，我们可以认为TCP/IP协议中传输的信息是字节序列。如何发送和解析信息需要一定的应用程序协议。

2.信息编码：

首先是Java里对基本整型的处理，发送时，要注意：1）每种数据类型的字节个数；2）这些字节的发送顺序是怎样的？（little-endian还是

big-endian）；3）所传输的数值是有符号的（signed）还是无符号的（unsigned）。具体编码时采用位操作（移位和屏蔽）就可以了。

具体在Java里，可以采用DataOutputStream类和ByteArrayOutputStream来实现。恢复时可以采用

DataInputStream类和ByteArrayInputStream类。

其次，字符串和文本，在一组符号与一组整数之间的映射称为编码字符集（coded character

set）。发送者与接收者必须在符号与整数的映射方式上达成共识，才能使用文本信息进行通信，最简单的方法就是定义一个标准字符集。具体编码时采用

String的getBytes()方法。

最后，位操作。如果设置一个特定的设为1，先设置好掩码(mask)，之后用或操作；要清空特定一位，用与操作。

3.成帧与解析

成帧（framing）技术解决了接收端如何定位消息的首位位置的问题。

如果接收者试图从套接字中读取比消息本身更多的字节，将可能发生以下两种情况之一：如果信道中没有其他消息，接收者将阻塞等待，同时无法处理接收

到的消息；如果发送者也在等待接收端的响应消息，则会形成死锁（dealock）；另一方面，如果信道中还有其他消息，则接收者会将后面消息的一部分甚至

全部读到第一条消息中去，这将产生一些协议错误。因此，在使用TCP套接字时，成帧就是一个非常重要的考虑因素。

有两个技术：

1.基于定界符（Delimiter-based）：消息的结束由一个唯一的标记（unique

marker）指出，即发送者在传输完数据后显式添加的一个特殊字节序列。这个特殊标记不能在传输的数据中出现。幸运的是，填充（stuffing）技术

能够对消息中出现的定界符进行修改，从而使接收者不将其识别为定界符。在接收者扫描定界符时，还能识别出修改过的数据，并在输出消息中对其进行还原，从而

使其与原始消息一致。

2.显式长度（Explicit length）：在变长字段或消息前附加一个固定大小的字段，用来指示该字段或消息中包含了多少字节。这种方法要确定消息长度的上限，以确定保存这个长度需要的字节数。

接口：

Java代码 import java.io.IOException; import java.io.OutputStream; public interface Framer { void frameMsg(byte [] message,OutputStream out) throws IOException; byte [] nextMsg() throws IOException; }

定界符的方式：

Java代码 import java.io.ByteArrayOutputStream; import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; public class DelimFramer implements Framer { private InputStream in;//data source; private static final byte DELIMTER=(byte)'\n';//message delimiter public DelimFramer(InputStream in){ this.in=in; } @Override public void frameMsg(byte[] message, OutputStream out) throws IOException { //ensure that the message dose not contain the delimiter for(byte b:message){ if(b==DELIMTER) throw new IOException("Message contains delimiter"); } out.write(message); out.write(DELIMTER); out.flush(); } @Override public byte[] nextMsg() throws IOException { ByteArrayOutputStream messageBuffer=new ByteArrayOutputStream(); int nextByte; while((nextByte=in.read())!=DELIMTER){ if(nextByte==-1){//end of stream? if(messageBuffer.size()==0){ return null; }else{ throw new EOFException("Non-empty message without delimiter"); } } messageBuffer.write(nextByte); } return messageBuffer.toByteArray(); } }

显式长度方法：

Java代码 import java.io.DataInputStream; import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; public class LengthFramer implements Framer { public static final int MAXMESSAGELENGTH=65535; public static final int BYTEMASK=0xff; public static final int SHOTMASK=0xffff; public static final int BYTESHIFT=8; private DataInputStream in;// wrapper for data I/O public LengthFramer(InputStream in) throws IOException{ this.in=new DataInputStream(in); } @Override public void frameMsg(byte[] message, OutputStream out) throws IOException { if(message.lengthMAXMESSAGELENGTH){ throw new IOException("message too long"); } //write length prefix out.write((message.lengthBYTEMASK)BYTEMASK); out.write(message.lengthBYTEMASK); //write message out.write(message); out.flush(); } @Override public byte[] nextMsg() throws IOException { int length; try{ length=in.readUnsignedShort(); }catch(EOFException e){ //no (or 1 byte) message; return null; } //0=length=65535; byte [] msg=new byte[length]; in.readFully(msg);//if exception,it's a framing error; return msg; } }

编写一个简单的TCP通信程序。服务器发送“你好我是服务器”，客户端接收该信息并显示在屏幕上。用Java写

1、服务器端

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

public class SocketServer {

    private static final int PORT = 8088;

    public static void main(String[] args) {

        ServerSocket server = null;

        try {

            server = new ServerSocket(PORT);

            while (true) {

                Socket client = server.accept();

                new Thread(new Server(client)).start();

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

}

class Server implements Runnable {

    private Socket client;

    public Server(Socket client) {

        this.client = client;

    }

    public void run() {

        DataOutputStream output = null;

        try {

            output = new DataOutputStream(client.getOutputStream());

            output.writeUTF("你好我是服务器");

        } catch (IOException e) {

            e.printStackTrace();

        } finally {

            try {

                if (output != null) output.close();

                output = null;

            } catch (IOException e) {}

        }

    }

}

2、客户端

import java.io.DataInputStream;

import java.io.IOException;

import java.net.Socket;

import java.net.UnknownHostException;

public class Client extends Socket {

    private static final int PORT = 8088;

    public static void main(String[] args) {

        Socket socket = null;

        try {

            socket = new Socket("127.0.0.1", PORT);

            DataInputStream in = new DataInputStream(socket.getInputStream());

            String res = in.readUTF();

            System.out.println(res);

            if (in != null) in.close();

        } catch (UnknownHostException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        } finally {

            if (socket != null) {

                try {

                    socket.close();

                } catch (IOException e) {}

            }

        }

    }

}

java如何实现基于TCP协议的socket传输

服务端监听：ServerSocket

server=new

ServerSocket(port);//port：绑定的端口号

Socket

client=server.accept();//监听端口，一旦取得连接则获得客户端的socket连接对象client

客户端：

Socket

s=new

Socket(ip,port);//要连接的服务器的ip以及端口号

如果正常连接上之后，socket的对象可以获得InputStream和OutputStreame，然后就可以进行通信了

完成通信之后，执行socket对象的close（）方法关闭连接，完成一次完整的socket连接

用java编写一个能进行简单TCP/IP通信的C/S程序

import java.net.ServerSocket;

import java.net.Socket;

public class TcpServer

{

public static void main(String[] args) throws Exception

{

// 创建服务器端的socket对象

ServerSocket ss = new ServerSocket(5000);

// 监听连接

Socket socket = ss.accept();

// 直到连接建立好之后代码才会往下执行

System.out.println("Connected Successfully!");

}

}

import java.net.Socket;

public class TcpClient

{

public static void main(String[] args) throws Exception

{

Socket socket = new Socket("127.0.0.1", 5000);

}

}

TCP和UDP通信有什么区别 如何分别用java实现？

TCP是面向连接，UDP面向非连接，资料不复制，在这里简单说下：\x0d\x0aTCP建立连接时需要传说的三次握手，服务端与客户端需要确认对方身份而已，建立好连接后，就开始传递消息，直到有一方断开连接位置。 就好比两个人打电话，要先通了才能说话。\x0d\x0aUDP只是数据报发送，它的优点速度快，并非要向TCP那样麻烦建立，它只负责将信息发出，但是并不确保信息的准确完整性等，就好比发短信，短信是出去了，但是中间是否有问题，是否对方手机能收到就不管了。\x0d\x0a在java中想要实现上述两种协议通信，可采用socket建立连接，socket可以理解为码头，其实是套接字，这里简单说下，就好比两个城市运输货物，通过码头走货一样。至于如何通过socket建立两个连接，网上资料多的是，在这里不复制例子了。

java中实现tcp通讯的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于、java中实现tcp通讯的信息别忘了在本站进行查找喔。