java客户端发消息到服务端
代码
如下
newClient.java
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class newClient extends JFrame {
private JPanel p = new JPanel();
private JTextField jtf1 = new JTextField();
private JTextArea jta1 = new JTextArea();
private DataOutputStream toserver;
private DataInputStream fromserver;
private JButton button = new JButton("发送");
// private Socket client =null;
public newClient() {
p.setLayout(new BorderLayout());
JPanel p2 = new JPanel();
p2.setLayout(new BorderLayout());
p2.add(jtf1, BorderLayout.CENTER);
p2.add((new JLabel("寒冰射手是lol最强的英雄")), BorderLayout.SOUTH);
p2.add(button, BorderLayout.EAST);
p.add(p2, BorderLayout.SOUTH);
p.add(jta1, BorderLayout.CENTER);
this.setTitle("最简单的发送消息软件");
this.add(p);
this.setSize(500, 250);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);
button.addActionListener(new buttonListener());
try {
Socket client = new Socket("115.159.180.185", 4322); ////////端口 和 ip 改成 和 服务器 对应
toserver = new DataOutputStream(client.getOutputStream());
fromserver = new DataInputStream(client.getInputStream());
while (true) {
String msg = fromserver.readUTF();
if (msg != null)
jta1.append(msg + '\n');
}
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
private class buttonListener implements ActionListener {
@Override
public void actionPerformed(ActionEvent e) {
String str = jtf1.getText().toString();
try {
// toserver = new DataOutputStream(client.getOutputStream());
// fromserver = new DataInputStream(client.getInputStream());
//
toserver.writeUTF(str);
toserver.flush();
} catch (UnknownHostException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
public static void main(String[] args) {
new newClient();
}
}
import java.awt.BorderLayout;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
public class chatServer extends JFrame {
private static JTextArea jta = new JTextArea();
private ServerSocket server;
private static List<Socket> list = new ArrayList<Socket>();
private ExecutorService exec;
public chatServer() {
setLayout(new BorderLayout());
add(new JScrollPane(jta), BorderLayout.CENTER);
setTitle("聊天室消息接受器");
setSize(500, 300);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setVisible(true);
try {
server = new ServerSocket(4322);
exec = Executors.newCachedThreadPool();
jta.append("服务器已经启动\n");
Socket client = null;
while (true) {
client = server.accept();
list.add(client);
exec.execute(new Task(client));
}
} catch (Exception e) {
}
}
static class Task implements Runnable {
private Socket client;
private DataInputStream fromclient;
private DataOutputStream toclient;
String msg;
public Task(Socket client) throws IOException {
this.client = client;
fromclient = new DataInputStream(client.getInputStream());
}
public void run() {
try {
while ((msg = fromclient.readUTF()) != null) {
msg = '[' + client.getPort() + "]说:" + msg;
jta.append(msg + '\n');
sendMessage();
}
} catch (Exception e) {
}
}
public void sendMessage() throws IOException {
for (Socket client : list) {
toclient = new DataOutputStream(client.getOutputStream());
toclient.writeUTF(msg);
}
}
}
public static void main(String[] args) {
new chatServer();
}
}
- JAVA SOCKET 服务端/客户端可随时从任意一方发消息的例子
- Socket通讯-C#客户端与Java服务端通讯(发送消息和文件)
- java scoket客户端服务端发送消息
- JAVA 网络编程 Socket 详细说明,实现客户端和服务端相互推送消息
- ios消息推送客户端和服务端实现带代码(java)
- java客户端发送消息到服务端
- [JAVA]多人聊天室控制台实现,服务端向所有客户端下发消息实现
- 使用eclipse paho在java端实现MQTT消息的收发(客户端与服务端实例)
- Java服务端和安卓客户端对消息的加密
- 简单java Web Service服务端和Android客户端
- kafka安装以及常见问题的解决【如:服务端是ok的,java客户端却始终调不通】
- java实现服务端守护进程来监听客户端通过上传json文件写数据到hbase中
- 原来dubbo 还支持 golang 呢,可以用相互调用,相爱了。使用java 做服务端,golang做客户端
- 简单的unity 客户端与服务端互相发送消息
- java客户端与服务端通信Tcp/Ip
- 文件上传简单服务端和客户端 Java 实现
- Java Tomcat SSL 服务端/客户端双向认证(一)
- Java网络编程之简单的服务端客户端应用实例
- 基于TCP实现简单的客户端服务端的消息传递
- VC客户端与Java服务端Socket通讯简例