我有以下情况，
Client_MultipleMessages.java:
public class Client_MultipleMessages {
public static void main(String[] args) {
Socket clientSocket = null;
SocketAddress sockaddr = null;
boolean IsSocketCreated = false;
String p_Response = "";
OutputStream outToServer = null;
InputStream in = null;
String strRequestString = "";
try{
clientSocket = new Socket();
sockaddr = new InetSocketAddress("192.168.121.121", 1234);
try{
clientSocket.connect(sockaddr, 1000);
if (clientSocket.isConnected()){
IsSocketCreated = true;
}
}catch(Exception e){
System.out.println("Exception while creating socket,Reason is:"+ e.getMessage());
}
int index = 1;
String req = "REGISTRATION_REQUEST";
while(index <= 2){
if(clientSocket.isConnected()){
outToServer = clientSocket.getOutputStream();
System.out.println("Request "+index+":"+req);
outToServer.write(req.getBytes());
outToServer.flush();
//clientSocket.setSoTimeout(1000);
in = clientSocket.getInputStream();
int i = -1;
while((i = in.read()) > 0){
p_Response += (char) i;
}
System.out.println("Response "+index+":"+p_Response);
}
index++;
req = "LERGD_ALLOCATE_MSISDN";
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}
Server_MultipleMessages.java
public class Server_MultipleMessages {
public static void main(String[] args) {
try{
ServerSocket Server = new ServerSocket (1234);
while(true){
Socket socket = Server.accept();
String fromclient = "";
BufferedReader inFromClient = null;
PrintWriter outToClient = null;
String strresponse = "";
try{
int reqCount = 1;
socket.setSoTimeout(2000);
while(reqCount <= 2){
System.out.println("Request-"+reqCount);
inFromClient = new BufferedReader(new InputStreamReader(socket.getInputStream()));
outToClient = new PrintWriter(socket.getOutputStream(),true);
char data[] = new char[1200];
inFromClient.read(data);
for (int i = 0; i < data.length; i++) {
fromclient = fromclient + Character.toString(data[i]);
}
System.out.println("XML Request is from client: "+fromclient+"\n\n");
String returnDesc = "success";
if(fromclient.contains("REGISTRATION_REQUEST")){
System.out.println("Request if for Registeration !!");
strresponse = "<REGISTRATION_RESPONSE><HEADER><ERROR_CODE>" + 0 + "</ERROR_CODE> <ERROR_DESC>" + returnDesc + "</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>";
}else if(fromclient.contains("LERGD_ALLOCATE_MSISDN")){
System.out.println("Request is for allocate Msisdnm !!");
strresponse = "<RESPONSE><HEADER><TRANSACTION_ID>123456</TRANSACTION_ID><REQUEST_TYPE>LERGD_ALLOCATE_MSISDN</REQUEST_TYPE><ERROR_CODE>" + 0 + "</ERROR_CODE><ERROR_DESC>" + returnDesc + "</ERROR_DESC></HEADER><BODY><ACTION_TAKEN>B</ACTION_TAKEN><ALLOCATED_MSISDN>7525600000</ALLOCATED_MSISDN></BODY></RESPONSE>";
}else{
System.out.println("Invalid Request from client !!");
}
System.out.println("XML Response to be send to client: "+strresponse+"\n\n");
outToClient.print(strresponse);
outToClient.flush();
strresponse = "";
fromclient = "";
reqCount++;
}
}catch(Exception ex){
ex.printStackTrace();
}finally{
if(!socket.isClosed()){
socket.close();
}
}
}
}catch(Exception ex){
System.out.println("Error in ProcessXmlRequest : "+ex.getMessage());
}
}}
服务器端输出:
Request-1
XML Request is from client: REGISTRATION_REQUEST
Request if for Registeration !!
XML Response to be send to client: <REGISTRATION_RESPONSE><HEADER><ERROR_CODE>0</ERROR_CODE><ERROR_DESC>success</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>
Request-2
java.net.SocketTimeoutException: Read timed out
客户端输出:
Request 1:REGISTRATION_REQUEST
Response 1:<REGISTRATION_RESPONSE><HEADER><ERROR_CODE>0</ERROR_CODE><ERROR_DESC>success</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>
Request 2:LERGD_ALLOCATE_MSISDN
Response 2:<REGISTRATION_RESPONSE><HEADER><ERROR_CODE>0</ERROR_CODE><ERROR_DESC>success</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>
最佳答案
您的客户端一直读取响应直到流结束，这只会在对等方关闭套接字时发生，这使得不可能进行多次交换。您需要设计另一种方法来分隔消息。在这种情况下，仅发送和接收线就足够了。
关于Java TCP 在同一个套接字上的客户端和服务器端之间发送和接收多条消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22420342/
我正在尝试使用ruby和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封，在我看来soap请求没有正确的命名空间。任何人都可以建议我
我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..
使用带有Rails插件的vim，您可以创建一个迁移文件，然后一次性打开该文件吗？textmate也可以这样吗？ 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件，这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails，您可以创建一个新的迁移文件并一次性打开它吗？，我们在StackOverflow上找到一个类似的问题： https://sta
我需要从一个View访问多个模型。以前，我的links_controller仅用于提供以不同方式排序的链接资源。现在我想包括一个部分(我假设)显示按分数排序的顶级用户(@users=User.all.sort_by(&:score))我知道我可以将此代码插入每个链接操作并从View访问它，但这似乎不是“ruby方式”，我将需要在不久的将来访问更多模型。这可能会变得很脏，是否有针对这种情况的任何技术？注意事项:我认为我的应用程序正朝着单一格式和动态页面内容的方向发展，本质上是一个典型的网络应用程序。我知道before_filter但考虑到我希望应用程序进入的方向，这似乎很麻烦。最终从任何
我想要做的是有2个不同的Controller，client和test_client。客户端Controller已经构建，我想创建一个test_clientController，我可以使用它来玩弄客户端的UI并根据需要进行调整。我主要是想绕过我在客户端中内置的验证及其对加载数据的管理Controller的依赖。所以我希望test_clientController加载示例数据集，然后呈现客户端Controller的索引View，以便我可以调整客户端UI。就是这样。我在test_clients索引方法中试过这个:classTestClientdefindexrender:template=>
设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline，但已经有几个月没有使用它了。现在，在Ruby1.9.2上全新安装时，它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗？ 最佳答案
如果您尝试在Ruby中的nil对象上调用方法，则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而，有一个tryRails中的方法，如果它被发送到一个nil对象，它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常？ 最佳答案 像Ruby中的所有其他对象
关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗？通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串？SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复？
最近，当我启动我的Rails服务器时，我收到了一长串警告。虽然它不影响我的应用程序，但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次？当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗？/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru
在Rails4.0.2中，我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常，但在生产环境中它会抛出如下错误，ActionView::Template::Error(noimplicitconversionofnilintoString)在View中，create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo