Java实现TCP互发消息
本文实例为大家分享了Java实现TCP互发消息的具体代码，供大家参考，具体内容如下
TCP客户端：
package tcp;
import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
public class TcpClient {
public static void main(String[] args) {
Socket socket =null;
OutputStream os =null;
try {
//创建socket对象，指明服务器端的ip和端口号
InetAddress inet = InetAddress.getByName("127.0.0.1");
socket = new Socket(inet, 8888);
//获取一个输出流，用于输出数据
os = socket.getOutputStream();
//写出数据的操作
os.write("你好，我是客户端".getBytes());
}catch(IOException e){
e.printStackTrace();
}finally {
//资源的关闭
if(os!=null){
try{
os.close();
}catch (IOException e){
e.printStackTrace();
}
}
if(socket!=null){
try {
socket.close();
}catch (IOException e){
e.printStackTrace();
}
}
}
}
}
TCP服务端：
package tcp;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
class TcpServer{
public static void main(String[] args) {
ServerSocket ss=null;
Socket socket=null;
InputStream is=null;
ByteArrayOutputStream baos =null;
try {
//创建服务器端的ServerSocket,指明自己的端口
ss = new ServerSocket(8888);
//调用accept()表示接收来自于客户端的socket
socket = ss.accept();
//获取输入流中的数据
is = socket.getInputStream();
/*读取输入流中的数据（ByteArrayOutputStream可以把字节一次性记录下来，
这样就可以避免一些字符的字节码不一致导致发送后解析出现乱码；
ByteArrayOutputStream的功能与StringBuilder的作用有异曲同工之妙。）
*/
baos = new ByteArrayOutputStream();
byte[] buffer = new byte[5];
int len;
while ((len = is.read(buffer)) != -1) {
baos.write(buffer, 0, len);
}
System.out.println(baos.toString());
}catch (IOException e){
e.printStackTrace();
}
finally{
//关闭流
if (baos!=null){
try {
baos.close();
}catch (IOException e){
e.printStackTrace();
}
}
if (is!=null){
try {
is.close();
}catch (IOException e){
e.printStackTrace();
}
}
if (socket!=null){
try {
socket.close();
}catch (IOException e){
e.printStackTrace();
}
}
if (ss!=null){
try {
ss.close();
}catch (IOException e){
e.printStackTrace();
}
}
}
}
}
注意：在Intellij idea中运行时，需先打开两个端的平行运行设置，操作如下：
最后的运行结果如下：
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。
相关推荐
-
java基于TCP协议实现聊天程序
JAVA程序设计之基于TCP协议的socket聊天程序 ,供大家参考,具体内容如下 一.程序实现的功能 1.进入客户端界面 2.创建昵称 3.群发信息 4.@私聊 5.下线通知 6.在线人数统计 二.整体架构图 三.简单介绍 本程序实现了基于TCP通信的聊天程序: 1 服务器端: 服务器端继承JFrame框架,添加组件.创建服务器端的socket,起一个线程池,每接收到一个客户端的连接,分配给其一个线程处理与客户端的通信,将每个客户端的昵称和服务器分配给其的输出流存储到哈希表中.通过检索哈希表中
-
java实现基于Tcp的socket聊天程序
对于步入编程行业不深的初学者或是已经有所领会的人来说,当学习一项新的技术的时候,非常渴望有一个附上注释完整的Demo.本人深有体会,网上的例子多到是很多,但是很杂不完整,写代码这种东西来不得半点马虎,要是错了一点,那也是运行不了的.这对于初学者来说更加的头疼,因为他根本不知道错在哪里,盲目的改只能错上加错.最后不得不去找找看看有没有能够直接运行的例子再加以模仿. 下面是博主在学习Java的socket时写的一个完整的例子,并且带上了完整的注释.它是一个简单的聊天程序,但是它可以设置任意多用户同时
-
Java基于Tcp/ip连接的多人交互聊天室
本文实例为大家分享了Java Socket编程实现多人交互聊天室的具体代码,供大家参考,具体内容如下 本项目由三个.java文件(Client.java.Server.java.UI.java)和一个.jpg图片文件组成UI.java是负责界面的构成文件.本聊天室的界面极其简单.主要分为两个界面:第一个是启动时需要登陆的界面如下: 输入名字进去以后就可以直接聊天 这个聊天室相当于群聊,每一个登陆进去的人发的信息,其他人都会收到. 使用指南: 1.运行Server.java文件,保证服务
-
java实现一个简单TCPSocket聊天室功能分享
本文实例为大家分享了java实现TCPSocket聊天室功能的相关代码,供大家参考,具体内容如下 1.TCPserver.java import java.net.*; import java.io.*; import java.util.*; import java.util.concurrent.*; public class TCPserver{ private static final int SERVERPORT = 8888; private ServerSocket MyServe
-
Java编程实现基于TCP协议的Socket聊天室示例
本文实例讲述了Java编程实现基于TCP协议的Socket聊天室.分享给大家供大家参考,具体如下: 这里使用Socket套接字进行编程,完成的是基于TCP可靠服务实现服务器与客户端的双通信. Server服务器端: package com.han; import java.awt.Container; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.Win
-
Java实现TCP互发消息
本文实例为大家分享了Java实现TCP互发消息的具体代码,供大家参考,具体内容如下 TCP客户端: package tcp; import java.io.IOException; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket; public class TcpClient { public static void main(String[] args) { Socket sock
-
Java实现UDP互发消息
本文实例为大家分享了Java实现UDP互发消息的具体代码,供大家参考,具体内容如下 UDP的发送端 package udp; /** UDP发送端 */ import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; public class UdpClient { public static void ma
-
微信公众平台 客服接口发消息的实现代码(Java接口开发)
微信公众平台技术文档:客服消息 一.接口说明 当用户和公众号产生特定动作的交互时(具体动作列表请见下方说明),微信将会把消息数据推送给开发者,开发者可以在一段时间内(目前修改为48小时)调用客服接口,通过POST一个JSON数据包来发送消息给普通用户.此接口主要用于客服等有人工消息处理环节的功能,方便开发者为用户提供更加优质的服务. 目前允许的动作列表如下(公众平台会根据运营情况更新该列表,不同动作触发后,允许的客服接口下发消息条数不同,下发条数达到上限后,会遇到错误返回码,具体请见返回码说明页
-
C# Winform 实现TCP发消息
服务端: 窗体 代码: using System; using System.Collections.Generic; using System.IO; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Windows.Forms; namespace SocketStudy { public partial class Form1 :
-
Java利用TCP实现服务端向客户端消息群发的示例代码
目录 前言 代码 tcp服务端代码 ServerThread 线程类 TcpTool 消息群发工具类 Tcp客户端代码 前言 项目需要和第三方厂商的服务需要用TCP协议通讯,考虑到彼此双方可能都会有断网重连.宕机重启的情况,需要保证 发生上述情况后,服务之间能够自动实现重新通信.研究测试之后整理如下代码实现.因为发现客户端重启后,对于服务端来说原来的客户端和服务端进程进程已经关闭,启动又和服务端新开了一个进程.所以实现原理就可以通过服务端向客户端群发实现,断开重新连接通讯. 代码 tcp服务端代
-
Java利用TCP协议实现客户端与服务器通信(附通信源码)
进行TCP协议网络程序的编写,关键在于ServerSocket套接字的熟练使用,TCP通信中所有的信息传输都是依托ServerSocket类的输入输出流进行的. 上一篇博客和大家分享了在网络编程中要注意的基础知识,关于IP.TCP.UDP以及端口和套接字的一些概念,想了解的小伙伴可以看我的这篇文章"盘点那些进行网络编程必须要知道的基础知识",那么今天大灰狼就来和大家分享一下如何使用TCP/IP进行网络程序的开发. TCP协议概念 先来了解一下TCP协议的基本概念. 我们知道TCP是可靠
-
Java应用层协议WebSocket实现消息推送
目录 前言 浏览器端 服务器端 前言 大部分的web开发者,开发的业务都是基于Http协议的:前端请求后端接口,携带参数,后端执行业务代码,再返回结果给前端.作者参与开发的项目,有一个报警推送的功能,服务端实时推送报警信息给浏览器端:还有像抖音里面,如果有人关注.回复你的评论时,抖音就会推送相关消息给你了,你就会收到一条消息. 有些同学会说了,基于Http协议也能实现啊:前端定时访问后端(每隔3s或者几秒),后端返回消息数据,前端拿到后弹出消息.这种方式太low了,而且每个浏览器都这样,
-
java微信开发第二步 获取消息和回复消息
接着上一篇java微信开发API第一步 服务器接入进行学习,下面介绍java微信开发第二步:获取消息和回复消息,具体内容如下 * 本示例根据微信开发文档:http://mp.weixin.qq.com/wiki/home/index.html最新版(4/3/2016 5:34:36 PM )进行开发演示. * 编辑平台:myeclipse10.7+win32+jdk1.7+tomcat7.0 * 服务器:阿里云 windows server 2008 64bits * 平台要求:servlet
-
Java调用微信客服消息实现发货通知的方法详解
本文实例讲述了Java调用微信客服消息实现发货通知的方法.分享给大家供大家参考,具体如下: 微信文档地址:https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140547&token=&lang=zh_CN 个人说明:这是一个样例,微信客户消息有很多种,我现在用的是公众号发送消息.样子如下图. 说明:下面开始代码部分了. 1.首先看微信文档.这里才是我们需要的 这里是说发消息要POST请求这个接口:https://a
-
Java微信公众平台之消息管理
Java微信公众平台开发之消息管理,一定要先看下官方文档 微信消息管理分为接收普通消息.接收事件推送.发送消息(被动回复).客服消息.群发消息.模板消息这几部分 一.接收普通消息 当普通微信用户向公众账号发消息时,微信服务器将POST消息的XML数据包到开发者填写的URL上. 关于MsgId,官方给出解释,相当于每个消息ID,关于重试的消息排重,推荐使用msgid排重.微信服务器在五秒内收不到响应会断掉连接,并且重新发起请求,总共重试三次. 比如文本消息的Xml示例 <xml> <ToU